@@ -449,8 +449,7 @@ def __init__(
449449 plugin .list_files ,
450450 ]
451451 chat_options = create_agent_chat_options ()
452- super ().__init__ (
453- chat_client = chat_client ,
452+ return chat_client .create_agent (
454453 name = name ,
455454 description = description ,
456455 instructions = instructions ,
@@ -639,6 +638,7 @@ async def async_analyze_default(
639638 )
640639
641640 logger .info ("Building Sequential workflow..." )
641+ print ("Building Sequential workflow..." )
642642 workflow = (
643643 SequentialBuilder ()
644644 .participants (
@@ -652,20 +652,24 @@ async def async_analyze_default(
652652 )
653653
654654 logger .info ("executing run..." )
655+ print ("Executing run..." )
655656
656657 async def _run () -> str :
657658 final_text : str = ""
659+ print ("running workflow run stream..." )
658660 async for event in workflow .run_stream (analysis_prompt ):
659661 # Lifecycle: executor invoked
660662 if isinstance (event , ExecutorInvokedEvent ):
661663 exec_id = getattr (event , "executor_id" , None )
662664 logger .info (f"[ExecutorInvoked] executor={ exec_id } " )
665+ print (f"[ExecutorInvoked] executor={ exec_id } " )
663666 continue
664667
665668 # Lifecycle: executor completed
666669 if isinstance (event , ExecutorCompletedEvent ):
667670 exec_id = getattr (event , "executor_id" , None )
668671 logger .info (f"[ExecutorCompleted] executor={ exec_id } " )
672+ print (f"[ExecutorCompleted] executor={ exec_id } " )
669673 continue
670674
671675 # Final aggregated output from SequentialBuilder: list[ChatMessage]
0 commit comments