@@ -418,11 +418,24 @@ def dummy_task(self):
418418@pytest .mark .parametrize ("newrelic_order" , ["sentry_first" , "sentry_last" ])
419419def test_newrelic_interference (init_celery , newrelic_order , celery_invocation ):
420420 def instrument_newrelic ():
421- import celery .app .trace as celery_mod
422- from newrelic .hooks .application_celery import instrument_celery_execute_trace
423-
424- assert hasattr (celery_mod , "build_tracer" )
425- instrument_celery_execute_trace (celery_mod )
421+ try :
422+ # older newrelic versions
423+ from newrelic .hooks .application_celery import (
424+ instrument_celery_execute_trace ,
425+ )
426+ import celery .app .trace as celery_trace_module
427+
428+ assert hasattr (celery_trace_module , "build_tracer" )
429+ instrument_celery_execute_trace (celery_trace_module )
430+
431+ except ImportError :
432+ # newer newrelic versions
433+ from newrelic .hooks .application_celery import instrument_celery_app_base
434+ import celery .app as celery_app_module
435+
436+ assert hasattr (celery_app_module , "Celery" )
437+ assert hasattr (celery_app_module .Celery , "send_task" )
438+ instrument_celery_app_base (celery_app_module )
426439
427440 if newrelic_order == "sentry_first" :
428441 celery = init_celery ()
0 commit comments