Skip to content

Commit dbf413f

Browse files
add flush
1 parent c752264 commit dbf413f

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

tests/integrations/ray/test_ray.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@ def example_task(span_streaming: bool):
102102
},
103103
):
104104
...
105+
sentry_sdk.flush()
105106
else:
106107
with sentry_sdk.start_span(op="task", name="example task step"):
107108
...
@@ -116,6 +117,7 @@ def example_task_with_kwargs(span_streaming: bool, **kwargs):
116117
name="example task step", attributes={"sentry.op": "task"}
117118
):
118119
...
120+
sentry_sdk.flush()
119121
else:
120122
with sentry_sdk.start_span(op="task", name="example task step"):
121123
...

0 commit comments

Comments
 (0)