We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 67ec039 commit 3896794Copy full SHA for 3896794
services/storage/src/simcore_service_storage/modules/celery/worker.py
@@ -17,8 +17,8 @@ def __init__(self, celery_app: Celery) -> None:
17
18
def register_task(self, fn: Callable, task_name: str | None = None) -> None:
19
name = task_name or fn.__name__
20
- _logger.info("Registering %s task", name)
21
- self.celery_app.task(name=name, base=AbortableTask, bind=True)(fn)
+ with log_context(_logger, logging.INFO, msg=f"Registering {name} task"):
+ self.celery_app.task(name=name, base=AbortableTask, bind=True)(fn)
22
23
def set_task_progress(
24
self, task_name: str, task_id: TaskID, report: ProgressReport
0 commit comments