From 41f7056b20fbada5ef73ab720f9a35963d28fca5 Mon Sep 17 00:00:00 2001 From: Jimmy Royer Date: Wed, 21 Aug 2024 10:38:21 -0400 Subject: [PATCH] Disable x-ray by removing signals registration (#2260) --- app/celery/celery.py | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) 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( {