ensure we dont finalize batch on just a liteagent finishing

This commit is contained in:
lorenzejay
2026-01-20 13:23:27 -08:00
parent 33d87bdf0f
commit 63a33cf01c

View File

@@ -1454,6 +1454,7 @@ class Flow(Generic[T], metaclass=FlowMeta):
)
self._event_futures.clear()
if not self.suppress_flow_events:
trace_listener = TraceCollectionListener()
if trace_listener.batch_manager.batch_owner_type == "flow":
if trace_listener.first_time_handler.is_first_time: