Skip to content

Commit 7d33b81

Browse files
committed
improve test
1 parent 60abc3b commit 7d33b81

1 file changed

Lines changed: 18 additions & 0 deletions

File tree

tests/integrations/huey/test_huey.py

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,24 @@ def retry_task(context):
158158
assert execute_span["name"] == "retry_task"
159159
assert execute_span["status"] == SpanStatus.OK
160160
assert len(huey) == 1
161+
162+
task = huey.dequeue()
163+
huey.execute(task)
164+
165+
sentry_sdk.get_client().flush()
166+
167+
all_payloads = [i.payload for i in items]
168+
task_spans = [
169+
p
170+
for p in all_payloads
171+
if p["attributes"]["sentry.op"] == OP.QUEUE_TASK_HUEY
172+
]
173+
assert len(task_spans) == 2
174+
retry_span = task_spans[1]
175+
assert retry_span["is_segment"]
176+
assert retry_span["name"] == "retry_task"
177+
assert retry_span["status"] == SpanStatus.OK
178+
assert len(huey) == 0
161179
else:
162180
events = capture_events()
163181
result = execute_huey_task(huey, retry_task, context)

0 commit comments

Comments
 (0)