Update app.py

app.py

@@ -138,23 +138,27 @@ def create_research_crew(topic: str):
         process=Process.sequential
     )
 
-def run_market_research(topic: str, progress_container, chat_container):
+def run_market_research(topic: str, progress_container, chat_container, log_container):
     """Run the market research process"""
     try:
         # Step 1: Initialize research team
         update_progress(progress_container, 0, "Initializing research team...")
+        log_container.write("Initializing research team...")
         time.sleep(1)
         
         # Step 2: Gathering market data
         update_progress(progress_container, 25, "Gathering market data...")
+        log_container.write("Research Analyst is gathering market data...")
         time.sleep(1)
         
         # Step 3: Analyzing findings
         update_progress(progress_container, 50, "Analyzing findings...")
+        log_container.write("Data Analyst is analyzing findings...")
         time.sleep(1)
         
         # Step 4: Compiling final report
         update_progress(progress_container, 75, "Compiling final report...")
+        log_container.write("Report Writer is compiling the final report...")
         
         # Create and run the crew
         crew = create_research_crew(topic)
@@ -173,6 +177,7 @@ def run_market_research(topic: str, progress_container, chat_container):
         
         update_progress(progress_container, 100, "Report completed!")
         st.success("✨ Report generation completed! You can now view the full report.")
+        log_container.write("Report generation completed!")
         
         # Store the report data in session state
         st.session_state.current_report = report_data
@@ -180,6 +185,7 @@ def run_market_research(topic: str, progress_container, chat_container):
         
     except Exception as e:
         st.error(f"Error during research: {str(e)}")
+        log_container.write(f"Error during research: {str(e)}")
 
 def main():
     st.title("🤖 AI Market Research Generator")
@@ -188,7 +194,7 @@ def main():
     if 'generating' not in st.session_state:
         st.session_state.generating = False
     
-    tab1, tab2 = st.tabs(["Generate Report", "View Reports"])
+    tab1, tab2, tab3 = st.tabs(["Generate Report", "View Reports", "Live Agent Log"])
     
     with tab1:
         col1, col2 = st.columns([2, 3])
@@ -210,12 +216,13 @@ def main():
                     else:
                         st.session_state.generating = True
                         
-                        # Create containers for progress and chat
+                        # Create containers for progress, chat, and log
                         progress_container = st.container()
                         chat_container = st.container()
+                        log_container = st.container()
                         
                         try:
-                            run_market_research(topic, progress_container, chat_container)
+                            run_market_research(topic, progress_container, chat_container, log_container)
                         except Exception as e:
                             st.error(f"Error generating report: {str(e)}")
                         finally:
@@ -278,6 +285,11 @@ def main():
                 st.subheader("Sources")
                 for source in report['sources']:
                     st.markdown(f"- {source}")
+    
+    with tab3:
+        st.subheader("Live Agent Log")
+        if 'log_container' in st.session_state:
+            st.session_state['log_container'].write("Live log will appear here...")
 
 def format_json_output(raw_output):
     """Format CrewOutput or raw string into proper JSON structure"""