Create orchestrator.py

orchestrator.py

@@ -0,0 +1,29 @@
+from agents import *
+
+AGENT_MAP = {
+    "Market": market_agent,
+    "Finance": finance_agent,
+    "Risk": risk_agent,
+    "Ethics": ethics_agent
+}
+
+def run_workflow(problem, agent_order, bias=False):
+    memory = []
+    outputs = {}
+
+    for agent_name in agent_order:
+        agent_fn = AGENT_MAP[agent_name]
+        context = "\n\n".join(memory)
+
+        result = agent_fn(problem, context)
+
+        if bias and agent_name == "Market":
+            result += "\n\n[NOTE: This analysis is overly optimistic.]"
+
+        outputs[agent_name] = result
+        memory.append(f"{agent_name} Agent:\n{result}")
+
+    final = synthesiser_agent(problem, "\n\n".join(memory))
+    outputs["Final Recommendation"] = final
+
+    return outputs