Update run_agentic_pipeline.py

run_agentic_pipeline.py

@@ -105,69 +105,3 @@ async def run_full_analytics_orchestration(
         logger.critical(f"Critical error during analytics orchestration: {e}", exc_info=True)
         return None
 
-# Example of how app.py might call this (for testing this module standalone)
-if __name__ == "__main__":
-    # This block is for testing `run_analytics_pipeline.py` directly.
-    # In a real scenario, `app.py` would import and call `run_full_analytics_orchestration`.
-    
-    # Ensure logging is set up for standalone test
-    from insight_and_tasks.utils.logging_config import setup_logging
-    setup_logging()
-
-    if not GOOGLE_API_KEY:
-        print("Please set the GOOGLE_API_KEY environment variable to run this test.")
-    else:
-        # Create mock token_state and filter parameters
-        mock_token_state = {
-            "bubble_posts_df": pd.DataFrame({
-                'id': [1, 2, 3], 'published_at': pd.to_datetime(['2023-01-01', '2023-07-15', '2023-12-31']),
-                'li_eb_label': ['A', 'B', 'A'], 'media_type': ['X', 'Y', 'X'], 'is_ad': [False, True, False],
-                'sentiment': ['pos', 'neg', 'neu'], 'engagement': [10,5,8], 'impressionCount': [100,50,80],
-                'clickCount': [1,2,3], 'likeCount': [8,3,6], 'commentCount': [1,1,1], 'shareCount': [1,1,1]
-            }),
-            "bubble_post_stats_df": pd.DataFrame({'post_id': [1, 2, 3]}), # Simplified
-            "bubble_mentions_df": pd.DataFrame({
-                'date': pd.to_datetime(['2023-06-01', '2023-08-20']), 'sentiment_label': ['Positive 👍', 'Negative 👎']
-            }),
-            "bubble_follower_stats_df": pd.DataFrame({
-                'category_name': ['2023-01-01', 'Industry A', '2023-02-01'], 
-                'follower_count_organic': [100, 500, 120],
-                'follower_count_paid': [10, 50, 20],
-                'follower_count_type': ['follower_gains_monthly', 'follower_industry', 'follower_gains_monthly']
-            }),
-            "config_date_col_posts": "published_at",
-            "config_date_col_mentions": "date",
-        }
-        mock_date_filter = "Ultimi 365 Giorni" # Example, adjust prepare_filtered_analytics_data if new options
-        # For "Ultimi 365 Giorni", prepare_filtered_analytics_data needs to handle it or be updated.
-        # Let's use a known filter for testing:
-        mock_date_filter = "Sempre"
-        mock_custom_start = None
-        mock_custom_end = None
-
-        logger.info("Running standalone test of run_full_analytics_orchestration...")
-        
-        async def test_run():
-            results = await run_full_analytics_orchestration(
-                mock_token_state, mock_date_filter, mock_custom_start, mock_custom_end
-            )
-
-            if results:
-                print("\n\n" + "="*30 + " MOCK ORCHESTRATION RESULTS " + "="*30)
-                print("\n--- Comprehensive Analysis Report ---")
-                print(results.get("comprehensive_analysis_report", "N/A"))
-                
-                print("\n--- Actionable OKRs and Tasks ---")
-                okrs_data = results.get("actionable_okrs_and_tasks")
-                if okrs_data:
-                    print(json.dumps(okrs_data, indent=2))
-                else:
-                    print("N/A")
-                
-                # Optionally print detailed metrics if needed for debugging
-                # print("\n--- Detailed Agent Metrics ---")
-                # print(json.dumps(results.get("detailed_metrics"), indent=2, default=str))
-            else:
-                print("Standalone test: Orchestration returned no results or failed.")
-
-        asyncio.run(test_run())