File tree Expand file tree Collapse file tree 1 file changed +0
-7
lines changed
services/storage/src/simcore_service_storage/modules/celery Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Original file line number Diff line number Diff line change 11import logging
2- from collections .abc import Callable
32
43from celery import Celery
5- from celery .contrib .abortable import AbortableTask
64from models_library .progress_bar import ProgressReport
75from servicelib .logging_utils import log_context
86
@@ -15,11 +13,6 @@ class CeleryTaskQueueWorker:
1513 def __init__ (self , celery_app : Celery ) -> None :
1614 self .celery_app = celery_app
1715
18- def register_task (self , fn : Callable , task_name : str | None = None ) -> None :
19- name = task_name or fn .__name__
20- with log_context (_logger , logging .INFO , msg = f"Registering { name } task" ):
21- self .celery_app .task (name = name , base = AbortableTask , bind = True )(fn )
22-
2316 def set_task_progress (
2417 self , task_name : str , task_id : TaskID , report : ProgressReport
2518 ) -> None :
You can’t perform that action at this time.
0 commit comments