diff --git a/libs/miroflow/src/miroflow/prebuilt/orchestrator.py b/libs/miroflow/src/miroflow/prebuilt/orchestrator.py index 066e86ff..48161c7f 100644 --- a/libs/miroflow/src/miroflow/prebuilt/orchestrator.py +++ b/libs/miroflow/src/miroflow/prebuilt/orchestrator.py @@ -734,7 +734,12 @@ async def run_main_agent( original_text = initial_user_content[0]["text"] initial_user_content[0]["text"] = original_text + o3_notes except Exception as e: - logger.warning(f"O3 hints extraction failed after retries: {str(e)}") + logger.error(f"O3 hints extraction failed after retries: {str(e)}") + self.task_log.log_step( + step_name="o3_hint", + message=f"[ERROR] O3 hint generation failed: {str(e)}", + status="failed", + ) o3_notes = "" # Continue execution but without O3 hints logger.info("Initial user input content: %s", initial_user_content) @@ -992,7 +997,6 @@ async def run_main_agent( task_description, final_answer_text, self.cfg.env.openai_api_key, - self.chinese_context, ) ) @@ -1037,6 +1041,11 @@ async def run_main_agent( logger.error( f"O3 final answer extraction failed after retries: {str(e)}" ) + self.task_log.log_step( + step_name="o3_final_answer", + message=f"[ERROR] O3 final answer extraction failed: {str(e)}", + status="failed", + ) # Continue using original final_answer_text else: