shaliz-kong commited on
Commit
1ef8ded
·
1 Parent(s): 90ddfb7

refactored import errors

Browse files
Files changed (2) hide show
  1. app/mapper.py +1 -1
  2. app/tasks/analytics_worker.py +2 -2
app/mapper.py CHANGED
@@ -25,7 +25,7 @@ from app.db import get_conn, ensure_raw_table, transactional_conn, ensure_schema
25
  from app.core.detection_engine import hybrid_detect_entity_type,hybrid_detect_industry_type
26
  from app.core.event_hub import event_hub
27
  from app.deps import get_sre_metrics
28
- from app.routers.health import emit_mapper_log
29
  # Prometheus metrics (free tier compatible)
30
  try:
31
  from prometheus_client import Counter, Histogram, Gauge
 
25
  from app.core.detection_engine import hybrid_detect_entity_type,hybrid_detect_industry_type
26
  from app.core.event_hub import event_hub
27
  from app.deps import get_sre_metrics
28
+ from app.core.sre_logging import emit_mapper_log
29
  # Prometheus metrics (free tier compatible)
30
  try:
31
  from prometheus_client import Counter, Histogram, Gauge
app/tasks/analytics_worker.py CHANGED
@@ -9,7 +9,8 @@ Changes:
9
  - Zero changes to core KPI calculation logic
10
  """
11
 
12
- import asyncio
 
13
  import json
14
  import os
15
  import time
@@ -26,7 +27,6 @@ from app.schemas.org_schema import OrgSchema
26
  from app.service.vector_service import VectorService, VectorStoreEventType, VectorMetrics
27
  from app.engine.kpi_calculators.registry import get_kpi_calculator_async
28
  from app.service.embedding_service import EmbeddingService
29
- from app.core.sre_logging import emit_worker_log
30
 
31
  # Configure structured logging for SRE tools (Loki, etc.)
32
  logging.basicConfig(
 
9
  - Zero changes to core KPI calculation logic
10
  """
11
 
12
+ import from app.core.sre_logging import emit_worker_log
13
+ asyncio
14
  import json
15
  import os
16
  import time
 
27
  from app.service.vector_service import VectorService, VectorStoreEventType, VectorMetrics
28
  from app.engine.kpi_calculators.registry import get_kpi_calculator_async
29
  from app.service.embedding_service import EmbeddingService
 
30
 
31
  # Configure structured logging for SRE tools (Loki, etc.)
32
  logging.basicConfig(