handlers

TogetherCrew · Jun 28, 2024 · df24bfb · df24bfb
1 parent dd2e9f8
commit df24bfb
Showing 1 changed file with 15 additions and 15 deletions.
diff --git a/worker/tasks.py b/worker/tasks.py
@@ -151,25 +151,25 @@ def worker_init_handler(sender=None, **kwargs):
     logging.info("worker_init_handler end.")
 
 
-# @worker_process_init.connect
-# def worker_process_init_handler(sender=None, **kwargs):
-#     logging.info("worker_process_init_handler start.")
-#     init_tracing()
-#     logging.info("worker_process_init_handler end.")
+@worker_process_init.connect
+def worker_process_init_handler(sender=None, **kwargs):
+    logging.info("worker_process_init_handler start.")
+    init_tracing()
+    logging.info("worker_process_init_handler end.")
 
 
-# @worker_ready.connect
-# def worker_ready_handler(sender=None, **kwargs):
-#     logging.info("worker_ready_handler start.")
-#     init_tracing()
-#     logging.info("worker_ready_handler end.")
+@worker_ready.connect
+def worker_ready_handler(sender=None, **kwargs):
+    logging.info("worker_ready_handler start.")
+    init_tracing()
+    logging.info("worker_ready_handler end.")
 
 
-# @task_prerun.connect
-# def task_prerun_handler(sender=None, **kwargs):
-#     logging.info("task_prerun_handler start.")
-#     init_tracing()
-#     logging.info("task_prerun_handler end.")
+@task_prerun.connect
+def task_prerun_handler(sender=None, **kwargs):
+    logging.info("task_prerun_handler start.")
+    init_tracing()
+    logging.info("task_prerun_handler end.")
 
 
 @task_postrun.connect