errors.txt

./Arc hived/_archive_2025-11-19/_archived_services/ai/neural_processor/main.py:311:5: F824 `global orchestrator` is unused: name is never assigned in scope
    global orchestrator
    ^
./Arc hived/_archive_2025-11-19/_archived_services/ai/neural_processor_service/app/main.py:506:30: F821 undefined name 'random'
                    "value": random.randint(10, 500),
                             ^
./Arc hived/_archive_2025-11-19/_archived_services/ai/neural_processor_service/app/main.py:507:34: F821 undefined name 'random'
                    "intensity": random.random(),
                                 ^
./Arc hived/_archive_2025-11-19/_archived_services/marketing/google-ads-lift/main.py:145:9: F821 undefined name 'conversion_lift_experiments'
        conversion_lift_experiments.inc()
        ^
./Arc hived/_archive_2025-11-19/_archived_services/marketing/google-ads-lift/main.py:269:13: F821 undefined name 'lift_results'
            lift_results.observe(lift_mean * 100)
            ^
./Arc hived/_archive_2025-11-19/_archived_services/marketing/google-ads-lift/main.py:270:13: F821 undefined name 'incremental_conversions'
            incremental_conversions.inc(incremental_conv)
            ^
./Arc hived/_archive_2025-11-19/archived/boss_agent/app_dynamic.py:87:16: F821 undefined name 'Response'
        return Response(generate_latest(), media_type=CONTENT_TYPE_LATEST)
               ^
./Arc hived/_archive_2025-11-19/boss-agent-mcp11_7/server.py:1244:50: F821 undefined name 'skills_file_path'
            "error": f"Skills file not found at {skills_file_path}",
                                                 ^
./Arc hived/_archive_2025-11-19/boss-agent-mcp11_7/server.py:1403:25: F821 undefined name 'gemini_error'
                    str(gemini_error) if "gemini_error" in locals() else "Not attempted"
                        ^
./miz-oki-adk-agents/boss/boss_agent.py:651:28: F821 undefined name 'MultiModelAgent'
def create_boss_agent() -> "MultiModelAgent":
                           ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:19:23: F821 undefined name 'PROJECT_ID'
        table_id = f"{PROJECT_ID}.{self.dataset_id}.srdal_decision_states"
                      ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:46:13: F821 undefined name 'logger'
            logger.error(f"BigQuery insert errors: {errors}")
            ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:49:9: F821 undefined name 'logger'
        logger.info(f"Stored decision state for campaign {campaign_id}: {decision_id}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:58:9: F821 undefined name 'logger'
        logger.error(f"Error storing decision state: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:76:20: F821 undefined name 'PROJECT_ID'
        query = f"""
            SELECT
                decision_id,
                campaign_id,
                srdal_stage,
                state_data,
                confidence_score,
                created_at,
                updated_at,
                agent_id,
                parent_decision_id
            FROM `{PROJECT_ID}.{self.dataset_id}.srdal_decision_states`
            WHERE campaign_id = @campaign_id
            ORDER BY created_at DESC
            LIMIT 1
        """
                   ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:111:9: F821 undefined name 'logger'
        logger.error(f"Error retrieving decision state: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:123:23: F821 undefined name 'PROJECT_ID'
        table_id = f"{PROJECT_ID}.{self.dataset_id}.srdal_execution_logs"
                      ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:158:13: F821 undefined name 'logger'
            logger.error(f"BigQuery insert errors: {errors}")
            ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:161:9: F821 undefined name 'logger'
        logger.info(f"Logged execution for campaign {campaign_id}: {execution_id}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:170:9: F821 undefined name 'logger'
        logger.error(f"Error logging execution: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:192:20: F821 undefined name 'PROJECT_ID'
        query = f"""
            SELECT
                execution_id,
                campaign_id,
                action_type,
                srdal_stage,
                status,
                execution_time,
                completed_time,
                result,
                error_message,
                metadata,
                cell_id,
                agent_id,
                duration_ms
            FROM `{PROJECT_ID}.{self.dataset_id}.srdal_execution_logs`
            WHERE campaign_id = @campaign_id
            ORDER BY execution_time DESC
            LIMIT @limit
        """
                   ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:233:9: F821 undefined name 'logger'
        logger.error(f"Error retrieving execution history: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:245:23: F821 undefined name 'PROJECT_ID'
        table_id = f"{PROJECT_ID}.{self.dataset_id}.srdal_learned_patterns"
                      ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:273:13: F821 undefined name 'logger'
            logger.error(f"BigQuery insert errors: {errors}")
            ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:276:9: F821 undefined name 'logger'
        logger.info(f"Stored learned pattern: {pattern_id}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:285:9: F821 undefined name 'logger'
        logger.error(f"Error storing learned pattern: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:304:24: F821 undefined name 'PROJECT_ID'
            query = f"""
                SELECT
                    pattern_id,
                    pattern_type,
                    pattern_data,
                    occurrences,
                    success_rate,
                    confidence,
                    first_observed_at,
                    last_observed_at,
                    context
                FROM `{PROJECT_ID}.{self.dataset_id}.srdal_learned_patterns`
                WHERE pattern_type = @pattern_type
                ORDER BY last_observed_at DESC
                LIMIT 100
            """
                       ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:328:24: F821 undefined name 'PROJECT_ID'
            query = f"""
                SELECT
                    pattern_id,
                    pattern_type,
                    pattern_data,
                    occurrences,
                    success_rate,
                    confidence,
                    first_observed_at,
                    last_observed_at,
                    context
                FROM `{PROJECT_ID}.{self.dataset_id}.srdal_learned_patterns`
                ORDER BY last_observed_at DESC
                LIMIT 100
            """
                       ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:358:9: F821 undefined name 'logger'
        logger.error(f"Error retrieving learned patterns: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:372:23: F821 undefined name 'PROJECT_ID'
        table_id = f"{PROJECT_ID}.{self.dataset_id}.srdal_relu_thresholds"
                      ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:405:13: F821 undefined name 'logger'
            logger.error(f"BigQuery insert errors: {errors}")
            ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:408:9: F821 undefined name 'logger'
        logger.info(f"Stored ReLU threshold for campaign {campaign_id}: {threshold_id}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:418:9: F821 undefined name 'logger'
        logger.error(f"Error storing ReLU threshold: {e}")
        ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:437:24: F821 undefined name 'PROJECT_ID'
            query = f"""
                SELECT
                    threshold_id,
                    srdal_stage,
                    metric_name,
                    threshold_value,
                    activation_function,
                    performance_metric,
                    updated_at,
                    performance_history
                FROM `{PROJECT_ID}.{self.dataset_id}.srdal_relu_thresholds`
                WHERE JSON_EXTRACT_SCALAR(performance_history, '$.campaign_id') = @campaign_id
                ORDER BY updated_at DESC
                LIMIT 100
            """
                       ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:458:24: F821 undefined name 'PROJECT_ID'
            query = f"""
                SELECT
                    threshold_id,
                    srdal_stage,
                    metric_name,
                    threshold_value,
                    activation_function,
                    performance_metric,
                    updated_at,
                    performance_history
                FROM `{PROJECT_ID}.{self.dataset_id}.srdal_relu_thresholds`
                ORDER BY updated_at DESC
                LIMIT 100
            """
                       ^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:489:9: F821 undefined name 'logger'
        logger.error(f"Error retrieving ReLU thresholds: {e}")
        ^
./miz-oki-adk-agents/specialists/budget_allocator.py:65:5: F824 `global _bigquery_client` is unused: name is never assigned in scope
    global _bigquery_client
    ^
./miz-oki-adk-agents/specialists/email_personalization.py:157:22: F821 undefined name 'pd'
                elif pd.isna(value):
                     ^
./miz-oki-adk-agents/specialists/email_personalization.py:321:26: F821 undefined name 'asyncio'
        response = await asyncio.to_thread(chat.send_message, prompt)
                         ^
./miz-oki-adk-agents/specialists/email_personalization.py:349:30: F821 undefined name 'asyncio'
            response = await asyncio.to_thread(
                             ^
./miz-oki-adk-agents/specialists/email_personalization.py:443:20: F821 undefined name 'asyncio'
    emails = await asyncio.gather(*tasks, return_exceptions=True)
                   ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:32:9: F821 undefined name 'get_campaign_metrics_tool'
        get_campaign_metrics_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:33:9: F821 undefined name 'get_knowledge_graph_insights_tool'
        get_knowledge_graph_insights_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:34:9: F821 undefined name 'detect_trends_tool'
        detect_trends_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:35:9: F821 undefined name 'get_contextual_signals_tool'
        get_contextual_signals_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:36:9: F821 undefined name 'analyze_causal_factors_tool'
        analyze_causal_factors_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:37:9: F821 undefined name 'get_learning_insights_tool'
        get_learning_insights_tool,
        ^
./miz-oki-adk-agents/specialists/performance_analyzer.py:38:9: F821 undefined name 'calculate_benchmark_comparison_tool'
        calculate_benchmark_comparison_tool,
        ^
./miz-oki-command-center-ui/backend/cognitive_core/adc_controllers.py:659:24: F821 undefined name 'defaultdict'
        self.metrics = defaultdict(list)
                       ^
./services/internal-email-agent/main.py:265:9: F821 undefined name 'emails_sent'
        emails_sent.inc()
        ^
./services/internal-email-agent/main.py:471:9: F821 undefined name 'emails_opened'
        emails_opened.labels(genuine=str(not is_bot)).inc()
        ^
./services/internal-email-agent/main.py:488:9: F821 undefined name 'emails_clicked'
        emails_clicked.inc()
        ^
./services/lift-engine/src/api/routes.py:189:23: F821 undefined name 'BudgetRecommender'
        recommender = BudgetRecommender(
                      ^
./services/lift-engine/src/core/bayesian.py:74:60: F821 undefined name 'AllocationResult'
        self, cycle_id: str, allocation_results: Dict[str, "AllocationResult"]
                                                           ^
./services/lift-engine/src/core/recommender.py:78:31: F821 undefined name 'Posterior'
        posteriors: Dict[str, "Posterior"],
                              ^
./services/lift-engine/src/core/recommender.py:124:20: F821 undefined name 'Posterior'
        posterior: "Posterior",
                   ^
./src/adapters/__init__.py:1:1: F821 undefined name 'src'
src / adapters / init.py
^
./src/adapters/__init__.py:1:7: F821 undefined name 'adapters'
src / adapters / init.py
      ^
./src/adapters/__init__.py:1:18: F821 undefined name 'init'
src / adapters / init.py
                 ^
./src/adapters/hybrid_kg_adapter.py:1:1: F821 undefined name 'src'
src / adapters / hybrid_kg_adapter.py
^
./src/adapters/hybrid_kg_adapter.py:1:7: F821 undefined name 'adapters'
src / adapters / hybrid_kg_adapter.py
      ^
./src/adapters/hybrid_kg_adapter.py:1:18: F821 undefined name 'hybrid_kg_adapter'
src / adapters / hybrid_kg_adapter.py
                 ^
./src/adapters/hybrid_kg_adapter.py:2:1: F821 undefined name 'python'
python
^
./src/adapters/hybrid_kg_adapter.py:4:1: F821 undefined name 'Collapse'
Collapse
^
./src/adapters/hybrid_kg_adapter.py:6:1: F821 undefined name 'Wrap'
Wrap
^
./src/adapters/hybrid_kg_adapter.py:8:1: F821 undefined name 'Run'
Run
^
./src/adapters/hybrid_kg_adapter.py:10:1: F821 undefined name 'Copy'
Copy
^
./src/cells/cell01_2/Cell1_2.py:247:5: F824 `global pubsub_topic_paths` is unused: name is never assigned in scope
    global bq_client, storage_client, pubsub_publisher, pubsub_topic_paths, CLEANING_TOPIC_PATH
    ^
./src/cells/cell01_3/Cell1_3.py:119:5: F824 `global pubsub_topic_paths` is unused: name is never assigned in scope
    global bq_client, pubsub_publisher, pubsub_topic_paths
    ^
./src/cells/cell02/multi_source_endpoints.py:387:5: F824 `global multi_source_ingestor` is unused: name is never assigned in scope
    global multi_source_ingestor
    ^
./src/cells/cell02/multi_source_endpoints.py:453:9: F824 `global multi_source_ingestor` is unused: name is never assigned in scope
        global multi_source_ingestor
        ^
./src/cells/cell02/multi_source_ingestor.py:608:33: F821 undefined name 'unified_dict'
                                unified_dict
                                ^
./src/cells/cell02/multi_source_ingestor.py:612:33: F821 undefined name 'unified_dict'
                                unified_dict
                                ^
./src/cells/cell02/multi_source_ingestor.py:616:33: F821 undefined name 'unified_dict'
                                unified_dict, enhanced=True
                                ^
./src/cells/cell02/multi_source_ingestor.py:620:33: F821 undefined name 'unified_dict'
                                unified_dict, enhanced=False
                                ^
./src/cells/cell02/multi_source_ingestor.py:624:33: F821 undefined name 'unified_dict'
                                unified_dict
                                ^
./src/cells/cell02/multi_source_ingestor.py:628:33: F821 undefined name 'unified_dict'
                                unified_dict
                                ^
./src/cells/cell03/v2/app.py:481:29: F821 undefined name 'cache_metrics'
        cache_stats = await cache_metrics()
                            ^
./src/cells/cell03/v2/app.py:1266:43: F821 undefined name 'timedelta'
        cutoff_time = datetime.utcnow() - timedelta(hours=time_window_hours)
                                          ^
./src/cells/cell03/v2/app.py:1412:32: F821 undefined name 'repository'
            repo_nodes = await repository.search_nodes(query, limit=limit)
                               ^
./src/cells/cell03/v2/app.py:1487:33: F821 undefined name 'repository'
            entity_node = await repository.get_node(entity)
                                ^
./src/cells/cell03/v2/app.py:1490:30: F821 undefined name 'repository'
                rels = await repository.get_node_relationships(entity)
                             ^
./src/cells/cell03/v2/app.py:1762:29: F821 undefined name 'cache_metrics'
        cache_stats = await cache_metrics()
                            ^
./src/cells/cell03/v2/repository.py:703:5: F824 `global _dual_backend_repository` is unused: name is never assigned in scope
    global _dual_backend_repository
    ^
./src/cells/cell03/v2/repository.py:747:5: F824 `global _dual_backend_repository` is unused: name is never assigned in scope
    global _dual_backend_repository
    ^
./src/cells/cell03/v2/security_middleware.py:59:5: F824 `global VALID_API_KEYS` is unused: name is never assigned in scope
    global VALID_API_KEYS
    ^
./src/cells/cell05/Cell5.py:505:33: F821 undefined name 'BaseADC'
    class SchedulingDecisionADC(BaseADC):
                                ^
./src/cells/cell05/Cell5.py:508:49: F821 undefined name 'ADCEvent'
        async def _calculate_score(self, event: ADCEvent) -> float:
                                                ^
./src/cells/cell05/Cell5.py:541:53: F821 undefined name 'ADCEvent'
        async def _get_data_confidence(self, event: ADCEvent) -> float:
                                                    ^
./src/cells/cell05/Cell5.py:574:35: F821 undefined name 'BaseADC'
    class OptimizationStrategyADC(BaseADC):
                                  ^
./src/cells/cell05/Cell5.py:577:49: F821 undefined name 'ADCEvent'
        async def _calculate_score(self, event: ADCEvent) -> float:
                                                ^
./src/cells/cell05/Cell5.py:598:53: F821 undefined name 'ADCEvent'
        async def _get_data_confidence(self, event: ADCEvent) -> float:
                                                    ^
./src/cells/cell05/Cell5.py:980:73: F821 undefined name 'ADCResult'
    async def _get_adc_scheduling_decision(self, schedule: Schedule) -> ADCResult:
                                                                        ^
./src/cells/cell05/Cell5.py:987:21: F821 undefined name 'ADCEvent'
        adc_event = ADCEvent(
                    ^
./src/cells/cell05/Cell5.py:1440:34: F821 undefined name 'LocalPattern'
        if not CORE_AVAILABLE or LocalPattern is None:
                                 ^
./src/cells/cell05/Cell5.py:1456:23: F821 undefined name 'LocalPattern'
            pattern = LocalPattern(
                      ^
./src/cells/cell05/Cell5.py:1498:35: F821 undefined name 'FederatedLearningManager'
                self.fl_manager = FederatedLearningManager(
                                  ^
./src/cells/cell05/Cell5.py:1680:10: F821 undefined name 'ADCResult'
    ) -> ADCResult:
         ^
./src/cells/cell05/Cell5.py:1693:21: F821 undefined name 'ADCEvent'
        adc_event = ADCEvent(
                    ^
./src/cells/cell05/Cell5.py:2135:25: F821 undefined name 'FederatedClient'
                        FederatedClient(
                        ^
./src/cells/cell05/Cell5.py:2184:39: F821 undefined name 'LocalPattern'
                if CORE_AVAILABLE and LocalPattern is not None:
                                      ^
./src/cells/cell05/Cell5.py:2185:31: F821 undefined name 'LocalPattern'
                    pattern = LocalPattern(
                              ^
./src/cells/cell05/Cell5.py:2223:62: F821 undefined name 'GlobalOptimization'
    async def _apply_global_optimization(self, optimization: GlobalOptimization):
                                                             ^
./src/cells/cell05/Cell5.py:2834:35: F821 undefined name 'LocalPattern'
            if CORE_AVAILABLE and LocalPattern is not None:
                                  ^
./src/cells/cell05/Cell5.py:2835:27: F821 undefined name 'LocalPattern'
                pattern = LocalPattern(**pattern_data)
                          ^
./src/cells/cell09/Cell9.py:953:12: F821 undefined name 'Response'
    return Response(content=generate_latest(), media_type=CONTENT_TYPE_LATEST)
           ^
./src/cells/cell09/Cell9_light.py:522:5: F821 undefined name 'FastAPIInstrumentor'
    FastAPIInstrumentor.instrument_app(app)
    ^
./src/cells/cell10/Cell10.py:255:2: F821 undefined name 'app'
@app.post("/feedback", tags=["Feedback"])
 ^
./src/cells/cell10/Cell10.py:958:12: F821 undefined name 'Response'
    return Response(content=generate_latest(), media_type=CONTENT_TYPE_LATEST)
           ^
./src/cells/cell12/Cell12.py:998:12: F821 undefined name 'Response'
    return Response(content=generate_latest(), media_type=CONTENT_TYPE_LATEST)
           ^
./src/cells/cell13/Cell13.py:368:32: F821 undefined name 'self'
            "causal_pathways": self._identify_causal_pathways(filtered_edges),
                               ^
./src/cells/cell13/Cell13.py:369:28: F821 undefined name 'self'
            "confounders": self._identify_confounders(filtered_edges),
                           ^
./src/cells/cell13/Cell13.py:370:26: F821 undefined name 'self'
            "mediators": self._identify_mediators(filtered_edges),
                         ^
./src/cells/cell21/cell_enhanced.py:121:31: F821 undefined name 'correlation_id'
            "correlation_id": correlation_id,
                              ^
./src/cells/cell27/Cell27.py:964:48: F821 undefined name 'timedelta'
                forecast_date = current_date + timedelta(days=i)
                                               ^
./src/cells/cell27/Cell27.py:991:44: F821 undefined name 'timedelta'
            forecast_date = current_date + timedelta(days=i)
                                           ^
./src/cells/cell29/Cell29.py:472:27: F821 undefined name 'os'
        firestore_project=os.getenv(
                          ^
./src/cells/cell29/Cell29.py:473:34: F821 undefined name 'os'
            "FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
                                 ^
./src/cells/cell29/Cell29.py:475:23: F821 undefined name 'os'
        kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
                      ^
./src/cells/cell29/Cell29.py:490:13: F821 undefined name 'os'
        env=os.getenv("APP_ENV", "prod"),
            ^
./src/cells/cell30/Cell30.py:566:27: F821 undefined name 'os'
        firestore_project=os.getenv(
                          ^
./src/cells/cell30/Cell30.py:567:34: F821 undefined name 'os'
            "FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
                                 ^
./src/cells/cell30/Cell30.py:569:23: F821 undefined name 'os'
        kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
                      ^
./src/cells/cell30/Cell30.py:583:13: F821 undefined name 'os'
        env=os.getenv("APP_ENV", "prod"),
            ^
./src/cells/cell30/Cell30.py:781:9: F821 undefined name 'logger'
        logger.info(
        ^
./src/cells/cell30/Cell30.py:814:9: F821 undefined name 'logger'
        logger.error(f"Error processing revenue signal: {e}")
        ^
./src/cells/cell31/Cell31.py:602:27: F821 undefined name 'os'
        firestore_project=os.getenv(
                          ^
./src/cells/cell31/Cell31.py:603:34: F821 undefined name 'os'
            "FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
                                 ^
./src/cells/cell31/Cell31.py:605:23: F821 undefined name 'os'
        kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
                      ^
./src/cells/cell31/Cell31.py:620:13: F821 undefined name 'os'
        env=os.getenv("APP_ENV", "prod"),
            ^
./src/cells/cell31/Cell31.py:829:9: F821 undefined name 'logger'
        logger.info(
        ^
./src/cells/cell31/Cell31.py:863:9: F821 undefined name 'logger'
        logger.error(f"Error processing budget signal: {e}")
        ^
./src/cells/cell32/app.py:659:28: F821 undefined name 'predict_pdc'
            result = await predict_pdc(pdc_event)
                           ^
./src/cells/cell32/app.py:682:28: F821 undefined name 'optimize_edges_endpoint'
            result = await optimize_edges_endpoint({"events": events})
                           ^
./src/cells/cell32/app.py:688:28: F821 undefined name 'get_pdc_metrics'
            result = await get_pdc_metrics()
                           ^
./src/core/federated_learning.py:26:5: F821 undefined name 'logger'
    logger.warning("Flower not available - using simulation mode")
    ^
./src/handlers/__init__.py:1:1: F821 undefined name 'src'
src / handlers / init.py
^
./src/handlers/__init__.py:1:7: F821 undefined name 'handlers'
src / handlers / init.py
      ^
./src/handlers/__init__.py:1:18: F821 undefined name 'init'
src / handlers / init.py
                 ^
./src/handlers/causal_handler.py:1:1: F821 undefined name 'src'
src / handlers / causal_handler.py
^
./src/handlers/causal_handler.py:1:7: F821 undefined name 'handlers'
src / handlers / causal_handler.py
      ^
./src/handlers/causal_handler.py:1:18: F821 undefined name 'causal_handler'
src / handlers / causal_handler.py
                 ^
./src/handlers/causal_handler.py:2:1: F821 undefined name 'python'
python
^
./src/handlers/causal_handler.py:4:1: F821 undefined name 'Collapse'
Collapse
^
./src/handlers/causal_handler.py:6:1: F821 undefined name 'Wrap'
Wrap
^
./src/handlers/causal_handler.py:8:1: F821 undefined name 'Run'
Run
^
./src/handlers/causal_handler.py:10:1: F821 undefined name 'Copy'
Copy
^
./src/handlers/causal_handler.py:27:27: F821 undefined name 'pd'
        prophet_model.fit(pd.DataFrame(...))
                          ^
./src/ingestion/__init__.py:1:1: F821 undefined name 'src'
src / ingestion / init.py
^
./src/ingestion/__init__.py:1:7: F821 undefined name 'ingestion'
src / ingestion / init.py
      ^
./src/ingestion/__init__.py:1:19: F821 undefined name 'init'
src / ingestion / init.py
                  ^
./src/ingestion/pipeline.py:1:1: F821 undefined name 'python'
python
^
./src/ingestion/pipeline.py:3:1: F821 undefined name 'Collapse'
Collapse
^
./src/ingestion/pipeline.py:5:1: F821 undefined name 'Wrap'
Wrap
^
./src/ingestion/pipeline.py:7:1: F821 undefined name 'Run'
Run
^
./src/ingestion/pipeline.py:9:1: F821 undefined name 'Copy'
Copy
^
./src/ingestion/pipeline.py:31:30: F821 undefined name 'uuid'
                "mizId": str(uuid.uuid4()),
                             ^
./src/ingestion/pipeline.py:53:20: F821 undefined name 'json'
            data = json.loads(msg.value)
                   ^
./src/ingestion/processors.py:1:1: F821 undefined name 'python'
python
^
./src/ingestion/processors.py:3:1: F821 undefined name 'Collapse'
Collapse
^
./src/ingestion/processors.py:5:1: F821 undefined name 'Wrap'
Wrap
^
./src/ingestion/processors.py:7:1: F821 undefined name 'Run'
Run
^
./src/ingestion/processors.py:9:1: F821 undefined name 'Copy'
Copy
^
./src/ingestion/processors.py:15:16: F821 undefined name 'pd'
        return pd.read_csv(file_path)
               ^
155   F821 undefined name 'random'
9     F824 `global orchestrator` is unused: name is never assigned in scope
164