andre/crewAI
1
0
Fork 0
mirror of https://github.com/crewAIInc/crewAI.git synced 2026-01-11 00:58:30 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Prevent crew inside flow to finish trace batch prematurely on failure

Browse Source
This commit is contained in:
Heitor Sammuel Carvalho
2025-12-18 09:22:37 -03:00
parent 8d0effafec
commit c97c5d27de
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/crewai/src/crewai/events/listeners/tracing/trace_listener.py
View File

@@ -221,11 +221,12 @@ class TraceCollectionListener(BaseEventListener):
@event_bus.on(CrewKickoffFailedEvent) @event_bus.on(CrewKickoffFailedEvent)
def on_crew_failed(source: Any, event: CrewKickoffFailedEvent) -> None: def on_crew_failed(source: Any, event: CrewKickoffFailedEvent) -> None:
self._handle_trace_event("crew_kickoff_failed", source, event) self._handle_trace_event("crew_kickoff_failed", source, event)
if self.first_time_handler.is_first_time: if self.batch_manager.batch_owner_type == "crew":
self.first_time_handler.mark_events_collected() if self.first_time_handler.is_first_time:
self.first_time_handler.handle_execution_completion() self.first_time_handler.mark_events_collected()
else: self.first_time_handler.handle_execution_completion()
self.batch_manager.finalize_batch() else:
self.batch_manager.finalize_batch()
@event_bus.on(TaskStartedEvent) @event_bus.on(TaskStartedEvent)
def on_task_started(source: Any, event: TaskStartedEvent) -> None: def on_task_started(source: Any, event: TaskStartedEvent) -> None: