@@ -606,7 +606,7 @@ def example_task():
606606def test_messaging_destination_name_default_exchange (
607607 mock_request , routing_key , init_celery , capture_events
608608):
609- celery_app = init_celery (enable_tracing = True )
609+ celery_app = init_celery (traces_sample_rate = 1.0 )
610610 events = capture_events ()
611611 mock_request .delivery_info = {"routing_key" : routing_key , "exchange" : "" }
612612
@@ -630,7 +630,7 @@ def test_messaging_destination_name_nondefault_exchange(
630630 that the routing key is the queue name. Other exchanges may not guarantee this
631631 behavior.
632632 """
633- celery_app = init_celery (enable_tracing = True )
633+ celery_app = init_celery (traces_sample_rate = 1.0 )
634634 events = capture_events ()
635635 mock_request .delivery_info = {"routing_key" : "celery" , "exchange" : "custom" }
636636
@@ -645,7 +645,7 @@ def task(): ...
645645
646646
647647def test_messaging_id (init_celery , capture_events ):
648- celery = init_celery (enable_tracing = True )
648+ celery = init_celery (traces_sample_rate = 1.0 )
649649 events = capture_events ()
650650
651651 @celery .task
@@ -659,7 +659,7 @@ def example_task(): ...
659659
660660
661661def test_retry_count_zero (init_celery , capture_events ):
662- celery = init_celery (enable_tracing = True )
662+ celery = init_celery (traces_sample_rate = 1.0 )
663663 events = capture_events ()
664664
665665 @celery .task ()
@@ -676,7 +676,7 @@ def task(): ...
676676def test_retry_count_nonzero (mock_request , init_celery , capture_events ):
677677 mock_request .retries = 3
678678
679- celery = init_celery (enable_tracing = True )
679+ celery = init_celery (traces_sample_rate = 1.0 )
680680 events = capture_events ()
681681
682682 @celery .task ()
@@ -691,7 +691,7 @@ def task(): ...
691691
692692@pytest .mark .parametrize ("system" , ("redis" , "amqp" ))
693693def test_messaging_system (system , init_celery , capture_events ):
694- celery = init_celery (enable_tracing = True )
694+ celery = init_celery (traces_sample_rate = 1.0 )
695695 events = capture_events ()
696696
697697 # Does not need to be a real URL, since we use always eager
@@ -716,7 +716,7 @@ def publish(*args, **kwargs):
716716
717717 monkeypatch .setattr (kombu .messaging .Producer , "_publish" , publish )
718718
719- sentry_init (integrations = [CeleryIntegration ()], enable_tracing = True )
719+ sentry_init (integrations = [CeleryIntegration ()], traces_sample_rate = 1.0 )
720720 celery = Celery (__name__ , broker = f"{ system } ://example.com" ) # noqa: E231
721721 events = capture_events ()
722722
@@ -754,7 +754,7 @@ def task(): ...
754754
755755
756756def tests_span_origin_consumer (init_celery , capture_events ):
757- celery = init_celery (enable_tracing = True )
757+ celery = init_celery (traces_sample_rate = 1.0 )
758758 celery .conf .broker_url = "redis://example.com" # noqa: E231
759759
760760 events = capture_events ()
@@ -778,7 +778,7 @@ def publish(*args, **kwargs):
778778
779779 monkeypatch .setattr (kombu .messaging .Producer , "_publish" , publish )
780780
781- sentry_init (integrations = [CeleryIntegration ()], enable_tracing = True )
781+ sentry_init (integrations = [CeleryIntegration ()], traces_sample_rate = 1.0 )
782782 celery = Celery (__name__ , broker = "redis://example.com" ) # noqa: E231
783783
784784 events = capture_events ()
@@ -807,7 +807,7 @@ def test_send_task_wrapped(
807807 capture_events ,
808808 reset_integrations ,
809809):
810- sentry_init (integrations = [CeleryIntegration ()], enable_tracing = True )
810+ sentry_init (integrations = [CeleryIntegration ()], traces_sample_rate = 1.0 )
811811 celery = Celery (__name__ , broker = "redis://example.com" ) # noqa: E231
812812
813813 events = capture_events ()
0 commit comments