2
2
3
3
pytest .importorskip ("celery" )
4
4
5
- from sentry_sdk import Hub , configure_scope
5
+ from sentry_sdk import Hub
6
6
from sentry_sdk .integrations .celery import CeleryIntegration
7
7
8
8
from celery import Celery , VERSION
@@ -69,8 +69,8 @@ def dummy_task(x, y):
69
69
assert not events
70
70
71
71
72
- def test_broken_prerun (capture_events , init_celery , connect_signal ):
73
- from celery .signals import task_prerun , task_postrun
72
+ def test_broken_prerun (init_celery , connect_signal ):
73
+ from celery .signals import task_prerun
74
74
75
75
def crash (* args , ** kwargs ):
76
76
1 / 0
@@ -81,7 +81,6 @@ def crash(*args, **kwargs):
81
81
connect_signal (task_prerun , crash )
82
82
celery = init_celery ()
83
83
84
- events = capture_events ()
85
84
assert len (Hub .current ._stack ) == 1
86
85
87
86
@celery .task (name = "dummy_task" )
@@ -90,7 +89,7 @@ def dummy_task(x, y):
90
89
return x / y
91
90
92
91
try :
93
- result = dummy_task .delay (2 , 2 )
92
+ dummy_task .delay (2 , 2 )
94
93
except ZeroDivisionError :
95
94
if VERSION >= (4 ,):
96
95
raise
0 commit comments