Update run_agentic_pipeline.py

run_agentic_pipeline.py

@@ -167,9 +167,11 @@ async def run_agentic_pipeline_autonomously(current_token_state_val, orchestrati
 
     if not current_token_state_val.get("agentic_pipeline_should_run_now", False):
         logging.info("Fetching existing data from Bubble as pipeline run is not required.")
+
+        report_df = current_token_state_val.get('bubble_agentic_analysis_data')
         
         # Call the new function to get reconstructed data
-        retrieved_data = fetch_and_reconstruct_data_from_bubble(org_urn)
+        retrieved_data = fetch_and_reconstruct_data_from_bubble(report_df)
 
         if not retrieved_data:
             logging.warning(f"No data found in Bubble for org_urn {org_urn}. Informing user.")