Peter Mutwiri commited on
Commit ·
12d1338
1
Parent(s): 1e5d7a4
fixed orgschema
Browse files
app/schemas/org_schema.py
CHANGED
|
@@ -4,8 +4,8 @@ import json
|
|
| 4 |
import logging
|
| 5 |
from datetime import datetime
|
| 6 |
from app.redis_client import redis
|
| 7 |
-
from app.
|
| 8 |
-
from app.
|
| 9 |
import duckdb
|
| 10 |
|
| 11 |
logger = logging.getLogger(__name__)
|
|
|
|
| 4 |
import logging
|
| 5 |
from datetime import datetime
|
| 6 |
from app.redis_client import redis
|
| 7 |
+
from app.service.llm_service import LLMService # Your existing LLM
|
| 8 |
+
from app.service.vector_service import VectorService # Your existing vector service
|
| 9 |
import duckdb
|
| 10 |
|
| 11 |
logger = logging.getLogger(__name__)
|
app/tasks/analytics_worker.py
CHANGED
|
@@ -10,8 +10,8 @@ import time
|
|
| 10 |
from app.redis_client import redis
|
| 11 |
from app.db import get_conn
|
| 12 |
from app.schemas.org_schema import OrgSchema # AI schema mapper
|
| 13 |
-
from app.
|
| 14 |
-
from app.
|
| 15 |
from app.engine.kpi_calculators.registry import get_kpi_calculator
|
| 16 |
from app.service.embedding_service import EmbeddingService # HF API fallback
|
| 17 |
|
|
|
|
| 10 |
from app.redis_client import redis
|
| 11 |
from app.db import get_conn
|
| 12 |
from app.schemas.org_schema import OrgSchema # AI schema mapper
|
| 13 |
+
from app.service.column_embedding_service import ColumnEmbeddingService # Vector engine
|
| 14 |
+
from app.service.vector_service import VectorService # AI query storage
|
| 15 |
from app.engine.kpi_calculators.registry import get_kpi_calculator
|
| 16 |
from app.service.embedding_service import EmbeddingService # HF API fallback
|
| 17 |
|