Fix syntax

pipeline.py

@@ -56,55 +56,56 @@ def run_gemini_in_thread(fn, *args, **kwargs):
 
 def _supervisor_logics(fn_name: str, args: tuple):
     """Get appropriate fallback value based on function name"""
-    if "breakdown" in fn_name:
-        return {
-            "sub_topics": [
-                {"id": 1, "topic": "Answer", "instruction": args[0] if args else "Address the question", "expected_tokens": 400, "priority": "high", "approach": "direct answer"}
-            ],
-            "strategy": "Direct answer (fallback)",
-            "exploration_note": "Gemini supervisor error"
-        }
-    elif "search_strategies" in fn_name:
-        return {
-            "search_strategies": [
-                {"id": 1, "strategy": args[0] if args else "", "target_sources": 2, "focus": "main query"}
-            ],
-            "max_strategies": 1
-        }
-    elif "rag_brainstorm" in fn_name:
-        return {
-            "contexts": [
-                {"id": 1, "context": args[1][:500] if len(args) > 1 else "", "focus": "retrieved information", "relevance": "high"}
-            ],
-            "max_contexts": 1
-        }
-    elif "synthesize" in fn_name:
-        # Return concatenated MedSwin answers as fallback
-        return "\n\n".join(args[1] if len(args) > 1 and args[1] else [])
-    elif "challenge" in fn_name:
-        return {"is_optimal": True, "completeness_score": 7, "accuracy_score": 7, "clarity_score": 7, "missing_aspects": [], "inaccuracies": [], "improvement_suggestions": [], "needs_more_context": False, "enhancement_instructions": ""}
-    elif "enhance_answer" in fn_name:
-        return args[1] if len(args) > 1 else ""
-    elif "check_clarity" in fn_name:
-        return {"is_unclear": False, "needs_search": False, "search_queries": []}
-    elif "clinical_intake_triage" in fn_name:
-        return {
-            "needs_additional_info": False,
-            "decision_reason": "Error fallback",
-            "max_rounds": args[2] if len(args) > 2 else 5,
-            "questions": [],
-            "initial_hypotheses": []
-        }
-    elif "summarize_clinical_insights" in fn_name:
-        return {
-            "patient_profile": "",
-            "refined_problem_statement": args[0] if args else "",
-            "key_findings": [],
-            "handoff_note": "Proceed with regular workflow."
-        }
-    else:
-        logger.warning(f"[GEMINI SUPERVISOR] Unknown function {fn_name}, returning None")
-        return None
+    try:
+        if "breakdown" in fn_name:
+            return {
+                "sub_topics": [
+                    {"id": 1, "topic": "Answer", "instruction": args[0] if args else "Address the question", "expected_tokens": 400, "priority": "high", "approach": "direct answer"}
+                ],
+                "strategy": "Direct answer (fallback)",
+                "exploration_note": "Gemini supervisor error"
+            }
+        elif "search_strategies" in fn_name:
+            return {
+                "search_strategies": [
+                    {"id": 1, "strategy": args[0] if args else "", "target_sources": 2, "focus": "main query"}
+                ],
+                "max_strategies": 1
+            }
+        elif "rag_brainstorm" in fn_name:
+            return {
+                "contexts": [
+                    {"id": 1, "context": args[1][:500] if len(args) > 1 else "", "focus": "retrieved information", "relevance": "high"}
+                ],
+                "max_contexts": 1
+            }
+        elif "synthesize" in fn_name:
+            # Return concatenated MedSwin answers as fallback
+            return "\n\n".join(args[1] if len(args) > 1 and args[1] else [])
+        elif "challenge" in fn_name:
+            return {"is_optimal": True, "completeness_score": 7, "accuracy_score": 7, "clarity_score": 7, "missing_aspects": [], "inaccuracies": [], "improvement_suggestions": [], "needs_more_context": False, "enhancement_instructions": ""}
+        elif "enhance_answer" in fn_name:
+            return args[1] if len(args) > 1 else ""
+        elif "check_clarity" in fn_name:
+            return {"is_unclear": False, "needs_search": False, "search_queries": []}
+        elif "clinical_intake_triage" in fn_name:
+            return {
+                "needs_additional_info": False,
+                "decision_reason": "Error fallback",
+                "max_rounds": args[2] if len(args) > 2 else 5,
+                "questions": [],
+                "initial_hypotheses": []
+            }
+        elif "summarize_clinical_insights" in fn_name:
+            return {
+                "patient_profile": "",
+                "refined_problem_statement": args[0] if args else "",
+                "key_findings": [],
+                "handoff_note": "Proceed with regular workflow."
+            }
+        else:
+            logger.warning(f"[GEMINI SUPERVISOR] Unknown function {fn_name}, returning None")
+            return None
     except Exception as e:
         logger.error(f"[GEMINI SUPERVISOR] Error running {fn.__name__} in thread: {e}")
         # Return appropriate fallback