| 17 | |
| 18 | |
| 19 | class Job(BaseModel): |
| 20 | id: str |
| 21 | task: str |
| 22 | params: dict[str, Any] = {} |
| 23 | status: str = "queued" |
| 24 | created_at: float | None = None |
| 25 | started_at: float | None = None |
| 26 | completed_at: float | None = None |
| 27 | result: dict[str, Any] | None = None |
| 28 | progress: dict[str, Any] | None = None |
| 29 | message_id: str = "" |
| 30 | queue_name: str = "" |
| 31 | |
| 32 | |
| 33 | def create_job(job_id: str, *, task: str, params: dict[str, Any]) -> Job: |