lint_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:505: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:506:34: F821 undefined name 'random'
"intensity": random.random(),
^
./Arc hived/_archive_2025-11-19/_archived_services/marketing/google-ads-lift/main.py:148: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:272: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:273:13: F821 undefined name 'incremental_conversions'
incremental_conversions.inc(incremental_conv)
^
./Arc hived/_archive_2025-11-19/archived/boss_agent/app_dynamic.py:85: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:1242: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:1401: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:900:16: E999 SyntaxError: unterminated f-string literal (detected at line 900)
./miz-oki-adk-agents/boss/srdal_bq_methods.py:18: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:45:13: F821 undefined name 'logger'
logger.error(f"BigQuery insert errors: {errors}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:48: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:57:9: F821 undefined name 'logger'
logger.error(f"Error storing decision state: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:75: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:110:9: F821 undefined name 'logger'
logger.error(f"Error retrieving decision state: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:122: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:157:13: F821 undefined name 'logger'
logger.error(f"BigQuery insert errors: {errors}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:160: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:169:9: F821 undefined name 'logger'
logger.error(f"Error logging execution: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:191: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:232:9: F821 undefined name 'logger'
logger.error(f"Error retrieving execution history: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:244: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:272:13: F821 undefined name 'logger'
logger.error(f"BigQuery insert errors: {errors}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:275:9: F821 undefined name 'logger'
logger.info(f"Stored learned pattern: {pattern_id}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:284:9: F821 undefined name 'logger'
logger.error(f"Error storing learned pattern: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:303: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:327: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:357:9: F821 undefined name 'logger'
logger.error(f"Error retrieving learned patterns: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:371: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:404:13: F821 undefined name 'logger'
logger.error(f"BigQuery insert errors: {errors}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:407: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:417:9: F821 undefined name 'logger'
logger.error(f"Error storing ReLU threshold: {e}")
^
./miz-oki-adk-agents/boss/srdal_bq_methods.py:436: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:457: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:488:9: F821 undefined name 'logger'
logger.error(f"Error retrieving ReLU thresholds: {e}")
^
./miz-oki-adk-agents/specialists/budget_allocator.py:67:5: F824 `global _bigquery_client` is unused: name is never assigned in scope
global _bigquery_client
^
./miz-oki-adk-agents/specialists/email_personalization.py:162:22: F821 undefined name 'pd'
elif pd.isna(value):
^
./miz-oki-adk-agents/specialists/email_personalization.py:326:26: F821 undefined name 'asyncio'
response = await asyncio.to_thread(chat.send_message, prompt)
^
./miz-oki-adk-agents/specialists/email_personalization.py:354:30: F821 undefined name 'asyncio'
response = await asyncio.to_thread(
^
./miz-oki-adk-agents/specialists/email_personalization.py:448: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:658:24: F821 undefined name 'defaultdict'
self.metrics = defaultdict(list)
^
./services/internal-email-agent/main.py:268:9: F821 undefined name 'emails_sent'
emails_sent.inc()
^
./services/internal-email-agent/main.py:474:9: F821 undefined name 'emails_opened'
emails_opened.labels(genuine=str(not is_bot)).inc()
^
./services/internal-email-agent/main.py:491:9: F821 undefined name 'emails_clicked'
emails_clicked.inc()
^
./services/lift-engine/src/api/routes.py:192:23: F821 undefined name 'BudgetRecommender'
recommender = BudgetRecommender(
^
./services/lift-engine/src/core/bayesian.py:73:60: F821 undefined name 'AllocationResult'
self, cycle_id: str, allocation_results: Dict[str, "AllocationResult"]
^
./services/lift-engine/src/core/recommender.py:77:31: F821 undefined name 'Posterior'
posteriors: Dict[str, "Posterior"],
^
./services/lift-engine/src/core/recommender.py:123: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:255: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:126: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: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
^
./src/cells/cell02/multi_source_ingestor.py:620:33: F821 undefined name 'unified_dict'
unified_dict, enhanced=True
^
./src/cells/cell02/multi_source_ingestor.py:624:33: F821 undefined name 'unified_dict'
unified_dict, enhanced=False
^
./src/cells/cell02/multi_source_ingestor.py:628:33: F821 undefined name 'unified_dict'
unified_dict
^
./src/cells/cell02/multi_source_ingestor.py:632:33: F821 undefined name 'unified_dict'
unified_dict
^
./src/cells/cell03/v2/app.py:504:29: F821 undefined name 'cache_metrics'
cache_stats = await cache_metrics()
^
./src/cells/cell03/v2/app.py:1289:43: F821 undefined name 'timedelta'
cutoff_time = datetime.utcnow() - timedelta(hours=time_window_hours)
^
./src/cells/cell03/v2/app.py:1435:32: F821 undefined name 'repository'
repo_nodes = await repository.search_nodes(query, limit=limit)
^
./src/cells/cell03/v2/app.py:1510:33: F821 undefined name 'repository'
entity_node = await repository.get_node(entity)
^
./src/cells/cell03/v2/app.py:1513:30: F821 undefined name 'repository'
rels = await repository.get_node_relationships(entity)
^
./src/cells/cell03/v2/app.py:1785:29: F821 undefined name 'cache_metrics'
cache_stats = await cache_metrics()
^
./src/cells/cell03/v2/repository.py:707:5: F824 `global _dual_backend_repository` is unused: name is never assigned in scope
global _dual_backend_repository
^
./src/cells/cell03/v2/repository.py:751: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:528:33: F821 undefined name 'BaseADC'
class SchedulingDecisionADC(BaseADC):
^
./src/cells/cell05/Cell5.py:531:49: F821 undefined name 'ADCEvent'
async def _calculate_score(self, event: ADCEvent) -> float:
^
./src/cells/cell05/Cell5.py:564:53: F821 undefined name 'ADCEvent'
async def _get_data_confidence(self, event: ADCEvent) -> float:
^
./src/cells/cell05/Cell5.py:597:35: F821 undefined name 'BaseADC'
class OptimizationStrategyADC(BaseADC):
^
./src/cells/cell05/Cell5.py:600:49: F821 undefined name 'ADCEvent'
async def _calculate_score(self, event: ADCEvent) -> float:
^
./src/cells/cell05/Cell5.py:621:53: F821 undefined name 'ADCEvent'
async def _get_data_confidence(self, event: ADCEvent) -> float:
^
./src/cells/cell05/Cell5.py:1003:73: F821 undefined name 'ADCResult'
async def _get_adc_scheduling_decision(self, schedule: Schedule) -> ADCResult:
^
./src/cells/cell05/Cell5.py:1010:21: F821 undefined name 'ADCEvent'
adc_event = ADCEvent(
^
./src/cells/cell05/Cell5.py:1463:34: F821 undefined name 'LocalPattern'
if not CORE_AVAILABLE or LocalPattern is None:
^
./src/cells/cell05/Cell5.py:1479:23: F821 undefined name 'LocalPattern'
pattern = LocalPattern(
^
./src/cells/cell05/Cell5.py:1521:35: F821 undefined name 'FederatedLearningManager'
self.fl_manager = FederatedLearningManager(
^
./src/cells/cell05/Cell5.py:1703:10: F821 undefined name 'ADCResult'
) -> ADCResult:
^
./src/cells/cell05/Cell5.py:1716:21: F821 undefined name 'ADCEvent'
adc_event = ADCEvent(
^
./src/cells/cell05/Cell5.py:2158:25: F821 undefined name 'FederatedClient'
FederatedClient(
^
./src/cells/cell05/Cell5.py:2207:39: F821 undefined name 'LocalPattern'
if CORE_AVAILABLE and LocalPattern is not None:
^
./src/cells/cell05/Cell5.py:2208:31: F821 undefined name 'LocalPattern'
pattern = LocalPattern(
^
./src/cells/cell05/Cell5.py:2246:62: F821 undefined name 'GlobalOptimization'
async def _apply_global_optimization(self, optimization: GlobalOptimization):
^
./src/cells/cell05/Cell5.py:2857:35: F821 undefined name 'LocalPattern'
if CORE_AVAILABLE and LocalPattern is not None:
^
./src/cells/cell05/Cell5.py:2858:27: F821 undefined name 'LocalPattern'
pattern = LocalPattern(**pattern_data)
^
./src/cells/cell09/Cell9.py:967:12: F821 undefined name 'Response'
return Response(content=generate_latest(), media_type=CONTENT_TYPE_LATEST)
^
./src/cells/cell09/Cell9_light.py:536:5: F821 undefined name 'FastAPIInstrumentor'
FastAPIInstrumentor.instrument_app(app)
^
./src/cells/cell10/Cell10.py:268:2: F821 undefined name 'app'
@app.post("/feedback", tags=["Feedback"])
^
./src/cells/cell10/Cell10.py:971:12: F821 undefined name 'Response'
return Response(content=generate_latest(), media_type=CONTENT_TYPE_LATEST)
^
./src/cells/cell12/Cell12.py:1001: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:120: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:473:27: F821 undefined name 'os'
firestore_project=os.getenv(
^
./src/cells/cell29/Cell29.py:474:34: F821 undefined name 'os'
"FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
^
./src/cells/cell29/Cell29.py:476:23: F821 undefined name 'os'
kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
^
./src/cells/cell29/Cell29.py:491:13: F821 undefined name 'os'
env=os.getenv("APP_ENV", "prod"),
^
./src/cells/cell30/Cell30.py:567:27: F821 undefined name 'os'
firestore_project=os.getenv(
^
./src/cells/cell30/Cell30.py:568:34: F821 undefined name 'os'
"FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
^
./src/cells/cell30/Cell30.py:570:23: F821 undefined name 'os'
kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
^
./src/cells/cell30/Cell30.py:584:13: F821 undefined name 'os'
env=os.getenv("APP_ENV", "prod"),
^
./src/cells/cell30/Cell30.py:782:9: F821 undefined name 'logger'
logger.info(
^
./src/cells/cell30/Cell30.py:815:9: F821 undefined name 'logger'
logger.error(f"Error processing revenue signal: {e}")
^
./src/cells/cell31/Cell31.py:603:27: F821 undefined name 'os'
firestore_project=os.getenv(
^
./src/cells/cell31/Cell31.py:604:34: F821 undefined name 'os'
"FIRESTORE_PROJECT", os.getenv("GCP_PROJECT", "your-project")
^
./src/cells/cell31/Cell31.py:606:23: F821 undefined name 'os'
kg_collection=os.getenv("KG_COLLECTION", "Cell03_KG"),
^
./src/cells/cell31/Cell31.py:621:13: F821 undefined name 'os'
env=os.getenv("APP_ENV", "prod"),
^
./src/cells/cell31/Cell31.py:830:9: F821 undefined name 'logger'
logger.info(
^
./src/cells/cell31/Cell31.py:864: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/cells/cell32/cell32-causal-roi-dashboard/cell32_integration.py:1225:16: E999 SyntaxError: invalid decimal literal
./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:26: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:30:30: F821 undefined name 'uuid'
"mizId": str(uuid.uuid4()),
^
./src/ingestion/pipeline.py:52: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)
^
./venv/lib/python3.13/site-packages/attr/_make.py:1436:9: F824 `nonlocal hash` is unused: name is never assigned in scope
nonlocal hash
^
./venv/lib/python3.13/site-packages/attr/_next_gen.py:398:9: F824 `nonlocal frozen` is unused: name is never assigned in scope
nonlocal frozen, on_setattr
^
./venv/lib/python3.13/site-packages/blib2to3/pgen2/tokenize.py:65:1: F822 undefined name 'generate_tokens' in __all__
__all__ = [x for x in dir(_token) if x[0] != "_"] + [
^
./venv/lib/python3.13/site-packages/blib2to3/pgen2/tokenize.py:65:1: F822 undefined name 'untokenize' in __all__
__all__ = [x for x in dir(_token) if x[0] != "_"] + [
^
./venv/lib/python3.13/site-packages/blib2to3/pytree.py:31:5: F824 `global _type_reprs` is unused: name is never assigned in scope
global _type_reprs
^
./venv/lib/python3.13/site-packages/flake8/checker.py:81:36: F821 undefined name '_mp_plugins'
filename=filename, plugins=_mp_plugins, options=_mp_options
^
./venv/lib/python3.13/site-packages/flake8/checker.py:81:57: F821 undefined name '_mp_options'
filename=filename, plugins=_mp_plugins, options=_mp_options
^
./venv/lib/python3.13/site-packages/google/protobuf/internal/containers.py:146:9: F821 undefined name 'warnings'
warnings.warn('Value is not iterable. Please remove the wrong '
^
./venv/lib/python3.13/site-packages/google/protobuf/internal/decoder.py:834:11: F821 undefined name 'message_factory'
message_factory.GetMessageClass(message_type)
^
./venv/lib/python3.13/site-packages/pip/_internal/utils/logging.py:287:5: F824 `global stderr_console` is unused: name is never assigned in scope
global _stdout_console, stderr_console
^
./venv/lib/python3.13/site-packages/pip/_vendor/distlib/compat.py:21:20: F821 undefined name 'basestring'
string_types = basestring,
^
./venv/lib/python3.13/site-packages/pip/_vendor/distlib/compat.py:22:17: F821 undefined name 'unicode'
text_type = unicode
^
./venv/lib/python3.13/site-packages/pip/_vendor/distlib/compat.py:31:26: F821 undefined name 'unicode'
if isinstance(s, unicode):
^
./venv/lib/python3.13/site-packages/pip/_vendor/distlib/compat.py:46:17: F821 undefined name 'raw_input'
raw_input = raw_input
^
./venv/lib/python3.13/site-packages/pip/_vendor/distlib/compat.py:504:37: F821 undefined name 'get_ident'
key = id(self), get_ident()
^
./venv/lib/python3.13/site-packages/pip/_vendor/pygments/lexer.py:229:27: F821 undefined name 'chardet'
enc = chardet.detect(text[:1024]) # Guess using first 1KB
^
./venv/lib/python3.13/site-packages/pip/_vendor/rich/console.py:523:15: F821 undefined name 'get_ipython'
ipython = get_ipython() # type: ignore[name-defined]
^
./venv/lib/python3.13/site-packages/pip/_vendor/rich/traceback.py:201:14: F821 undefined name 'get_ipython'
ip = get_ipython() # type: ignore[name-defined]
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:49:21: F821 undefined name 'basestring'
string_types = (basestring,)
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:50:27: F821 undefined name 'long'
integer_types = (int, long)
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:52:17: F821 undefined name 'unicode'
text_type = unicode
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:722:16: F821 undefined name 'unicode'
return unicode(s.replace(r"\\", r"\\\\"), "unicode_escape")
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:824:37: F821 undefined name 'basestring'
if not isinstance(data, basestring):
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:828:32: F821 undefined name 'file'
isinstance(fp, file)
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:829:38: F821 undefined name 'unicode'
and isinstance(data, unicode)
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:841:32: F821 undefined name 'unicode'
if isinstance(sep, unicode):
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:847:32: F821 undefined name 'unicode'
if isinstance(end, unicode):
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:855:36: F821 undefined name 'unicode'
if isinstance(arg, unicode):
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:859:23: F821 undefined name 'unicode'
newline = unicode("\n")
^
./venv/lib/python3.13/site-packages/pip/_vendor/urllib3/packages/six.py:860:21: F821 undefined name 'unicode'
space = unicode(" ")
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'AbstractSet' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'AnyStr' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'BinaryIO' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Callable' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Collection' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Container' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Dict' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'FrozenSet' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Hashable' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'IO' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'ItemsView' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Iterable' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Iterator' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'KeysView' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'List' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Mapping' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'MappingView' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Match' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'MutableMapping' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'MutableSequence' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'MutableSet' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Optional' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Pattern' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Reversible' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Sequence' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Set' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Sized' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'TextIO' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Tuple' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'Union' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'ValuesView' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'cast' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'no_type_check' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/typing_extensions.py:21:1: F822 undefined name 'no_type_check_decorator' in __all__
__all__ = [
^
./venv/lib/python3.13/site-packages/urllib3/util/request.py:233:13: F824 `nonlocal body` is unused: name is never assigned in scope
nonlocal body, blocksize
^
./venv/lib/python3.13/site-packages/urllib3/util/request.py:233:13: F824 `nonlocal blocksize` is unused: name is never assigned in scope
nonlocal body, blocksize
^
2 E999 SyntaxError: unterminated f-string literal (detected at line 900)
178 F821 undefined name 'random'
36 F822 undefined name 'generate_tokens' in __all__
15 F824 `global orchestrator` is unused: name is never assigned in scope
231