Newer
Older
vmk-360-data_collector / src / vmk_data_collector / schemas / raw_data.py
@Eugene Sukhodolskiy Eugene Sukhodolskiy 1 day ago 350 bytes feat: core pipeline + FastAPI API (Phases 0-6)
from typing import Any

from pydantic import BaseModel


class RawDataIngestRequest(BaseModel):
    source_slug: str
    external_id: str
    payload: dict[str, Any]


class IngestResponse(BaseModel):
    job_id: int
    property_id: int | None = None
    status: str
    reason: str | None = None
    message: str
    snapshot_id: int | None = None