Update services/report_data_handler.py

services/report_data_handler.py

@@ -15,35 +15,24 @@ logger = logging.getLogger(__name__)
 
 def fetch_latest_agentic_analysis(org_urn: str):
     """
-    Fetches the most recent agentic analysis for a given org_urn from Bubble.
-    Returns the analysis data (dict) and its timestamp, or None, None.
+    Fetches all agentic analysis data for a given org_urn from Bubble.
+    Returns the full dataframe and any error, or None, None.
     """
     if not org_urn:
         logger.warning("fetch_latest_agentic_analysis: org_urn is missing.")
-        return None
-
-    # Simpler: fetch all from this table (if it's not too large) or filter by org_urn
-    # This example assumes you might fetch more and then filter.
+        return None, None
+    
     report_data_df, error = fetch_linkedin_posts_data_from_bubble(
         data_type=BUBBLE_REPORT_TABLE_NAME,
-        org_urn=org_urn # Or use this if your function supports it for filtering
+        org_urn=org_urn
     )
-
+    
     if error or report_data_df is None or report_data_df.empty:
         logger.info(f"No existing agentic analysis found in Bubble for org_urn {org_urn} or error: {error}")
-        return None
-
-    # Filter for the specific org_urn if not done by the fetch call
-    quarter_report_data_df = report_data_df[report_data_df['type'] == 'Quarter'].copy()
-
-    if quarter_report_data_df.empty:
-        logger.info(f"No agentic analysis found for org_urn {org_urn} after filtering.")
-        return None
-
-    latest_analysis = quarter_report_data_df.sort_values(by='Created Date', ascending=False).iloc[0]
-
-    logger.info(f"Latest agentic analysis found for org_urn {org_urn}}")
-    return latest_report
+        return None, None
+    
+    logger.info(f"Agentic analysis data fetched for org_urn {org_urn}")
+    return report_data_df, None  # Return full dataframe and no error
 
 
 def save_agentic_analysis_results(