app/jobs/models.py

"""Job payloads for the Redis generation queue."""

from __future__ import annotations

from enum import Enum
from typing import Any

from pydantic import BaseModel, Field


class JobType(str, Enum):
    generate = "generate"
    agentic_full = "agentic_full"


class GenerationJob(BaseModel):
    """Serializable unit of work for ``jobs_worker.py``."""

    job_type: JobType
    report_id: str
    tenant_id: str
    payload: dict[str, Any] = Field(default_factory=dict)