diff --git a/app/celery/celery.py b/app/celery/celery.py index 7963a70f91..d824cf5e5e 100644 --- a/app/celery/celery.py +++ b/app/celery/celery.py @@ -105,14 +105,12 @@ def filter(self, record): @task_prerun.connect def add_id_to_logger(task_id, task, *args, **kwargs): - current_app.logger.info('this is a prerun test!') request_id = kwargs.get('notification_id', task_id) current_app.logger.addHandler(CeleryRequestIdFilter(request_id, f'celery-{request_id}')) @task_postrun.connect def id_cleanup_logger(task_id, task, *args, **kwargs): - current_app.logger.info('this is a postrun test!') request_id = kwargs.get('notification_id', task_id) for handler in current_app.logger.handlers: if handler.name == f'celery-{request_id}':