@@ -123,7 +123,8 @@ async def _get_manager_instructions_with_fallback_async(self, manager_task, mana
123123 schema = ManagerInstructions .model_json_schema ()
124124 props_desc = ", " .join ([f'"{ k } ": <{ v .get ("type" , "any" )} >' for k , v in schema .get ('properties' , {}).items ()])
125125 required_props = schema .get ('required' , [])
126- required_desc = f" (required: { ', ' .join (f'\" { p } \" ' for p in required_props )} )" if required_props else ""
126+ required_props_str = ', ' .join (f'"{ p } "' for p in required_props )
127+ required_desc = f" (required: { required_props_str } )" if required_props else ""
127128 json_structure_desc = "{" + props_desc + "}"
128129 enhanced_prompt = manager_prompt + f"\n \n IMPORTANT: Respond with valid JSON only, using this exact structure: { json_structure_desc } { required_desc } "
129130 except Exception as schema_error :
@@ -161,7 +162,8 @@ def _get_manager_instructions_with_fallback(self, manager_task, manager_prompt,
161162 schema = ManagerInstructions .model_json_schema ()
162163 props_desc = ", " .join ([f'"{ k } ": <{ v .get ("type" , "any" )} >' for k , v in schema .get ('properties' , {}).items ()])
163164 required_props = schema .get ('required' , [])
164- required_desc = f" (required: { ', ' .join (f'\" { p } \" ' for p in required_props )} )" if required_props else ""
165+ required_props_str = ', ' .join (f'"{ p } "' for p in required_props )
166+ required_desc = f" (required: { required_props_str } )" if required_props else ""
165167 json_structure_desc = "{" + props_desc + "}"
166168 enhanced_prompt = manager_prompt + f"\n \n IMPORTANT: Respond with valid JSON only, using this exact structure: { json_structure_desc } { required_desc } "
167169 except Exception as schema_error :
0 commit comments