o i, @sddlZddlZddlmZddlmZddlmZddlmZddlm Z ddl m Z e de ej d d d ej d ed ej d e d ddefddZdeeeffddZddZddZdS)N)config) patch_app) unpatch_app)PRODUCER_SERVICE)WORKER_SERVICE)asboolceleryDD_CELERY_DISTRIBUTED_TRACINGF)defaultDD_CELERY_PRODUCER_SERVICE_NAMEDD_CELERY_WORKER_SERVICE_NAME)distributed_tracingproducer_service_nameworker_service_namereturncCs ttjS)N)strr __version__rrY/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/internal/celery/patch.py get_versions rcCsddiS)Nrz>=4.4rrrrr_supported_versionssrcCttjdS)aInstrument Celery base application and the `TaskRegistry` so that any new registered task is automatically instrumented. In the case of Django-Celery integration, also the `@shared_task` decorator must be instrumented because Django doesn't use the Celery registry. N)rrCeleryrrrrpatch srcCr)z6Disconnect all signals and remove Tracing capabilitiesN)rrrrrrrunpatch)sr)osrddtracer#ddtrace.contrib.internal.celery.apprr)ddtrace.contrib.internal.celery.constantsrrddtrace.internal.utils.formatsr_addgetenvrrdictrrrrrrrs&