Update server.py

server.py

@@ -535,36 +535,36 @@ async def run_workflow(request: WorkflowRequest):
         
         agent_responses = {}
         
-        # for agent_name, agent_func in agents:
-        #     workflow_results.extend([agent_name, "-" * 30])
-        #     try:
-        #         response = agent_func(sample_alert)
-        #         workflow_results.append("✅ Message generated successfully")
-        #         agent_responses[agent_name] = response
+        for agent_name, agent_func in agents:
+            workflow_results.extend([agent_name, "-" * 30])
+            try:
+                response = agent_func(sample_alert)
+                workflow_results.append("✅ Message generated successfully")
+                agent_responses[agent_name] = response
                 
-        #         # Add preview for some agents
-        #         if "WhatsApp" in agent_name:
-        #             text = response.get('text', 'N/A')
-        #             workflow_results.append(f"   Preview: {text[:100]}..." if len(text) > 100 else f"   Preview: {text}")
-        #         elif "SMS" in agent_name:
-        #             workflow_results.append(f"   Preview: {str(response)[:100]}...")
+                # Add preview for some agents
+                if "WhatsApp" in agent_name:
+                    text = response.get('text', 'N/A')
+                    workflow_results.append(f"   Preview: {text[:100]}..." if len(text) > 100 else f"   Preview: {text}")
+                elif "SMS" in agent_name:
+                    workflow_results.append(f"   Preview: {str(response)[:100]}...")
                 
-        #     except Exception as e:
-        #         workflow_results.append(f"❌ Error: {str(e)}")
-        #         agent_responses[agent_name] = f"Error: {str(e)}"
+            except Exception as e:
+                workflow_results.append(f"❌ Error: {str(e)}")
+                agent_responses[agent_name] = f"Error: {str(e)}"
             
-        #     workflow_results.append("")
+            workflow_results.append("")
         
         # Summary
-        # workflow_results.extend([
-        #     "✅ Workflow Summary",
-        #     "-" * 30,
-        #     f"🎯 Successfully generated alerts for {sample_alert['location']['village']}, {request.district}",
-        #     f"📊 Data Sources: {sample_alert['data_source']}",
-        #     f"🤖 AI Enhanced: {'Yes' if sample_alert['alert']['ai_generated'] else 'No'}",
-        #     f"⏰ Generated at: {datetime.now().strftime('%Y-%m-%d %H:%M:%S UTC')}",
-        #     f"📱 Agents Processed: {len([r for r in agent_responses.values() if not str(r).startswith('Error:')])}/{len(agents)}"
-        # ])
+        workflow_results.extend([
+            "✅ Workflow Summary",
+            "-" * 30,
+            f"🎯 Successfully generated alerts for {sample_alert['location']['village']}, {request.district}",
+            f"📊 Data Sources: {sample_alert['data_source']}",
+            f"🤖 AI Enhanced: {'Yes' if sample_alert['alert']['ai_generated'] else 'No'}",
+            f"⏰ Generated at: {datetime.now().strftime('%Y-%m-%d %H:%M:%S UTC')}",
+            f"📱 Agents Processed: {len([r for r in agent_responses.values() if not str(r).startswith('Error:')])}/{len(agents)}"
+        ])
         
         # Generate CSV
         csv_content = generate_csv_export(sample_alert, agent_responses)