File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -270,16 +270,19 @@ async def on_executing(self, data):
270
270
if self .current_node :
271
271
self .remaining_nodes .discard (self .current_node )
272
272
self .update_overall_progress ()
273
- self .current_node = data ["node" ]
274
- self .log_node ("Executing" , data ["node" ])
273
+ # Use display_node if available, otherwise use node
274
+ node_id = data .get ("display_node" , data .get ('node' ))
275
+
276
+ self .current_node = node_id
277
+ self .log_node ("Executing" , node_id )
275
278
if self .ctx .get ("session_id" ):
276
279
await send_to_websocket (
277
280
self .ctx .get ("session_id" ),
278
281
{
279
282
"type" : "tool_call_progress" ,
280
283
"tool_call_id" : self .ctx .get ("tool_call_id" ),
281
284
"session_id" : self .ctx .get ("session_id" ),
282
- "update" : f"Executing { self .get_node_title (data [ 'node' ] )} " ,
285
+ "update" : f"Executing { self .get_node_title (node_id )} " ,
283
286
},
284
287
)
285
288
return True
You can’t perform that action at this time.
0 commit comments