Implement service-based model for jobs

app/app.py

@@ -0,0 +1,3 @@
+from app.main import app
+
+__all__ = ["app"]

app/db/base.py

@@ -0,0 +1,5 @@
+from sqlalchemy.orm import DeclarativeBase
+
+
+class Base(DeclarativeBase):
+    pass

app/db/models/__init__.py

@@ -0,0 +1,4 @@
+from app.db.base import Base
+from app.db.models.job import Job
+
+__all__ = ["Base", "Job"]

app/repositories/__init__.py

@@ -0,0 +1,3 @@
+from app.repositories.job_repository import JobRepository
+
+__all__ = ["JobRepository"]

app/schemas/__init__.py

@@ -0,0 +1,13 @@
+from app.schemas.job import (
+    JobCreate,
+    JobResponse,
+    JobStatusResponse,
+    JobResultResponse,
+)
+
+__all__ = [
+    "JobCreate",
+    "JobResponse",
+    "JobStatusResponse",
+    "JobResultResponse",
+]

app/schemas/job.py

@@ -0,0 +1,37 @@
+from datetime import datetime
+from typing import Any, Dict, List, Optional
+from pydantic import BaseModel, ConfigDict
+
+
+class JobBase(BaseModel):
+    filename: str
+
+
+class JobCreate(JobBase):
+    pass
+
+
+class JobResponse(JobBase):
+    model_config = ConfigDict(from_attributes=True)
+
+    id: str
+    status: str
+    row_count: Optional[int] = None
+    created_at: datetime
+    updated_at: datetime
+
+
+class JobStatusResponse(BaseModel):
+    model_config = ConfigDict(from_attributes=True)
+
+    id: str
+    status: str
+    summary: Optional[Dict[str, Any]] = None
+
+
+class JobResultResponse(BaseModel):
+    model_config = ConfigDict(from_attributes=True)
+
+    id: str
+    status: str
+    results: Optional[Dict[str, Any]] = None

app/services/__init__.py

@@ -0,0 +1,3 @@
+from app.services.job_service import JobService
+
+__all__ = ["JobService"]