From df24bfb7caf67e7741517f5d289b184829ed122c Mon Sep 17 00:00:00 2001 From: Cyrille Derche Date: Fri, 28 Jun 2024 17:44:48 +0200 Subject: [PATCH] handlers --- worker/tasks.py | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) diff --git a/worker/tasks.py b/worker/tasks.py index 4aea89f..e783356 100644 --- 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