fix: ensure end_all_traces is called at the end of all flow build events (#6991)

This commit is contained in:
Ítalo Johnny 2025-03-10 18:04:39 -03:00 committed by GitHub
commit cb61dded91
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -424,7 +424,9 @@ async def generate_flow_events(
)
event_manager.on_error(data=error_message.data)
raise
event_manager.on_end(data={})
await graph.end_all_traces()
await event_manager.queue.put((None, None, time.time()))