Skip to content

Commit

Permalink
Squash #Both patch celery for ddtrace in celery.py when celery instan…
Browse files Browse the repository at this point in the history
…ce intialized AND include ddtrace-run in command to initalize Celery ECS container
  • Loading branch information
MackHalliday committed Nov 20, 2024
1 parent 5564cfb commit 0da42e4
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions app/celery/celery.py
Original file line number Diff line number Diff line change
@@ -1,10 +1,15 @@
import time

from celery import Celery, Task
from ddtrace import patch

patch(celery=True)

from celery.signals import worker_process_shutdown, worker_shutting_down, worker_process_init
from flask import current_app



@worker_process_init.connect
def pool_worker_started(
*args,
Expand Down

0 comments on commit 0da42e4

Please sign in to comment.