diff --git a/app/celery/celery.py b/app/celery/celery.py index 17f39476d0..be5a5593aa 100644 --- a/app/celery/celery.py +++ b/app/celery/celery.py @@ -2,14 +2,7 @@ from flask import current_app -from app.aws.xray_celery_handlers import ( - xray_after_task_publish, - xray_before_task_publish, - xray_task_failure, - xray_task_postrun, - xray_task_prerun, -) -from celery import Celery, Task, signals +from celery import Celery, Task from celery.signals import worker_process_shutdown @@ -49,13 +42,6 @@ def init_app(self, app): task_cls=make_task(app), ) - # Register the xray handlers - signals.after_task_publish.connect(xray_after_task_publish) - signals.before_task_publish.connect(xray_before_task_publish) - signals.task_failure.connect(xray_task_failure) - signals.task_postrun.connect(xray_task_postrun) - signals.task_prerun.connect(xray_task_prerun) - # See https://docs.celeryproject.org/en/stable/userguide/configuration.html self.conf.update( {