File tree Expand file tree Collapse file tree 1 file changed +5
-6
lines changed
typescript-sdk/integrations/langgraph/python/ag_ui_langgraph Expand file tree Collapse file tree 1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -243,12 +243,6 @@ async def _handle_stream_events(self, input: RunAgentInput) -> AsyncGenerator[st
243
243
StepStartedEvent (type = EventType .STEP_STARTED , step_name = self .active_run ["node_name" ])
244
244
)
245
245
246
- # if tasks is None:
247
- yield self ._dispatch_event (
248
- StepFinishedEvent (type = EventType .STEP_FINISHED , step_name = self .active_run ["node_name" ])
249
- )
250
- self .active_run ["node_name" ] = None
251
-
252
246
state_values = state .values if state .values else state
253
247
yield self ._dispatch_event (
254
248
StateSnapshotEvent (type = EventType .STATE_SNAPSHOT , snapshot = self .get_state_snapshot (state_values ))
@@ -261,6 +255,11 @@ async def _handle_stream_events(self, input: RunAgentInput) -> AsyncGenerator[st
261
255
)
262
256
)
263
257
258
+ yield self ._dispatch_event (
259
+ StepFinishedEvent (type = EventType .STEP_FINISHED , step_name = self .active_run ["node_name" ])
260
+ )
261
+ self .active_run ["node_name" ] = None
262
+
264
263
yield self ._dispatch_event (
265
264
RunFinishedEvent (type = EventType .RUN_FINISHED , thread_id = thread_id , run_id = self .active_run ["id" ])
266
265
)
You can’t perform that action at this time.
0 commit comments