Add a job to the processing queue.
(self, job_id: str, job: JobStatus)
| 48 | |
| 49 | def add_job(self, job_id: str, job: JobStatus): |
| 50 | """Add a job to the processing queue.""" |
| 51 | self.job_status[job_id] = job |
| 52 | self.processing_queue.put(job_id) |
| 53 | |
| 54 | def get_job_status(self, job_id: str) -> JobStatus: |
| 55 | """Get job status by ID.""" |
| 56 | return self.job_status.get(job_id) |