[KM-556] move parquet_service from knowledge/ to storage/

src/knowledge/processing_service.py

@@ -7,7 +7,7 @@ from src.storage.az_blob.az_blob import blob_storage
 from src.db.postgres.models import Document as DBDocument
 from sqlalchemy.ext.asyncio import AsyncSession
 from src.middlewares.logging import get_logger
-from src.knowledge.parquet_service import upload_parquet
+from src.storage.parquet import upload_parquet
 from typing import List
 from datetime import datetime, timezone, timedelta
 import sys

src/query/executor/tabular.py

@@ -20,7 +20,7 @@ from typing import Any
 import pandas as pd
 
 from ...catalog.models import Catalog, Source, Table
-from ...knowledge.parquet_service import parquet_blob_name
+from ...storage.parquet import parquet_blob_name
 from ...middlewares.logging import get_logger
 from ..compiler.pandas import CompiledPandas, PandasCompiler
 from ..ir.models import QueryIR

src/query/executors/tabular.py

@@ -19,7 +19,7 @@ from pydantic import BaseModel
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from src.config.settings import settings
-from src.knowledge.parquet_service import download_parquet
+from src.storage.parquet import download_parquet
 from src.middlewares.logging import get_logger
 from src.query.base import BaseExecutor, QueryResult
 from src.retrieval.base import RetrievalResult

src/{knowledge/parquet_service.py → storage/parquet.py}

@@ -1,4 +1,4 @@
-"""Parquet service — converts, uploads, downloads, and deletes Parquet files for CSV/XLSX.
+"""Parquet storage helpers — converts, uploads, downloads, and deletes Parquet files for CSV/XLSX.
 
 Parquet files are stored in Azure Blob alongside the original document using
 a deterministic naming convention based on document_id: