Update run_agentic_pipeline.py

run_agentic_pipeline.py

@@ -28,6 +28,22 @@ from data_processing.analytics_data_processing import prepare_filtered_analytics
 # Placeholder for UI generator import - to be created later
 # from .insights_ui_generator import format_orchestration_results_for_ui 
 
+try:
+    from ui.insights_ui_generator import (
+        format_report_to_markdown,
+        extract_key_results_for_selection,
+        format_single_okr_for_display
+    )
+    AGENTIC_MODULES_LOADED = True
+except ImportError as e:
+    logging.error(f"Could not import agentic pipeline modules: {e}. Tabs 3 and 4 will be disabled.")
+    AGENTIC_MODULES_LOADED = False
+    async def run_full_analytics_orchestration(*args, **kwargs): return None # Placeholder
+    def format_report_to_markdown(report_string): return "Agentic modules not loaded. Report unavailable." # Placeholder
+    def extract_key_results_for_selection(okrs_dict): return [] # Placeholder
+    def format_single_okr_for_display(okr_data, **kwargs): return "Agentic modules not loaded. OKR display unavailable." # Placeholder
+
+
 logger = logging.getLogger(__name__)
 
 
@@ -109,7 +125,7 @@ async def run_full_analytics_orchestration(
 
 
 
-async def run_agentic_pipeline_autonomously(current_token_state_val):
+async def run_agentic_pipeline_autonomously(current_token_state_val, orchestration_raw_results_st,selected_key_result_ids_st):
     logging.info(f"Agentic pipeline check triggered for token_state update. Current token: {'Set' if current_token_state_val.get('token') else 'Not Set'}")
     # Initial state before pipeline runs or if skipped
     initial_yield = (