Update app.py

app.py

@@ -175,19 +175,28 @@ if "initialization_attempted" not in st.session_state:
 # Run workflow in separate thread
 def run_workflow_thread(workflow, alert):
     try:
-        # Log start of workflow
+        # Log start of workflow with more details
         logger.info(f"Starting workflow for alert: {alert}")
+        logger.info(f"Workflow object: {workflow}")
+        logger.info(f"Alert type: {type(alert)}")
+        
+        # Validate inputs
+        if not alert or not isinstance(alert, str):
+            raise ValueError("Invalid alert: Must be a non-empty string")
         
         # Update status
-        st.session_state.status_queue.put(("info", "Planning analysis approach..."))
-        st.session_state.current_step = "planning"
+        st.session_state.status_queue.put(("info", "Initializing workflow..."))
+        st.session_state.current_step = "initializing"
+        
+        # Log agent and workflow details
+        logger.info("Workflow initialization started")
         
-        # Run the workflow with more detailed logging
-        logger.info("Invoking workflow run...")
+        # Run the workflow
+        logger.info("Invoking workflow run method")
         result = workflow.run_workflow(alert)
         
-        # Log completion
-        logger.info("Workflow completed successfully")
+        # Log workflow result details
+        logger.info(f"Workflow completed. Status: {result.get('status', 'Unknown')}")
         
         # Store the result
         st.session_state.workflow_state = result
@@ -195,22 +204,33 @@ def run_workflow_thread(workflow, alert):
         # Update status
         st.session_state.status_queue.put(("success", "Analysis complete!"))
         st.session_state.current_step = "complete"
+        
+        logger.info("Workflow thread completed successfully")
+    
     except Exception as e:
-        # Capture the full stack trace
-        stack_trace = traceback.format_exc()
-        error_msg = f"Error: {str(e)}\n\nStack trace:\n{stack_trace}"
+        # Capture detailed error information
+        error_details = {
+            "error_message": str(e),
+            "traceback": traceback.format_exc(),
+            "alert": alert,
+            "workflow_object": str(workflow)
+        }
         
-        # Log the error
-        logger.error(error_msg)
+        # Log the error comprehensively
+        logger.error("Workflow thread failed")
+        logger.error(f"Error details: {json.dumps(error_details, indent=2)}")
         
-        # Update status with more details
-        st.session_state.status_queue.put(("error", f"Error: {str(e)}"))
+        # Update error state
+        st.session_state.status_queue.put((
+            "error", 
+            f"Workflow Execution Error: {str(e)}"
+        ))
         st.session_state.current_step = "error"
         
         # Store error details for debugging
         if "error_details" not in st.session_state:
             st.session_state.error_details = []
-        st.session_state.error_details.append(error_msg)
+        st.session_state.error_details.append(error_details)
 
 # Main application header
 st.title("🔮 Agentic Pharmaceutical Analytics Platform")