Skip to content

Commit

Permalink
Disable x-ray by removing signals registration (#2260)
Browse files Browse the repository at this point in the history
  • Loading branch information
jimleroyer authored Aug 21, 2024
1 parent fa7502d commit 41f7056
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions app/celery/celery.py
Original file line number Diff line number Diff line change
Expand Up @@ -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


Expand Down Expand Up @@ -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(
{
Expand Down

0 comments on commit 41f7056

Please sign in to comment.