Skip to content

Commit

Permalink
Xray celery rollback (#2251)
Browse files Browse the repository at this point in the history
* removing code for xray/celery because the sdk is causing errors

* fixinsg the formatting
  • Loading branch information
P0NDER0SA authored Aug 8, 2024
1 parent 257ba87 commit 5a1c7a5
Showing 1 changed file with 1 addition and 14 deletions.
15 changes: 1 addition & 14 deletions app/celery/scheduled_tasks.py
Original file line number Diff line number Diff line change
@@ -1,13 +1,6 @@
from datetime import datetime, timedelta
from typing import List, cast

from celery_aws_xray_sdk_extension.handlers import (
xray_after_task_publish,
xray_before_task_publish,
xray_task_failure,
xray_task_postrun,
xray_task_prerun,
)
from flask import current_app
from notifications_utils.statsd_decorators import statsd
from sqlalchemy import and_
Expand Down Expand Up @@ -56,13 +49,7 @@
)
from app.notifications.process_notifications import send_notification_to_queue
from app.v2.errors import JobIncompleteError
from celery import Task, signals

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)
from celery import Task

# https://stackoverflow.com/questions/63714223/correct-type-annotation-for-a-celery-task
save_smss = cast(Task, save_smss)
Expand Down

0 comments on commit 5a1c7a5

Please sign in to comment.