(job_id: str, message: str, level: str)
| 27 | |
| 28 | |
| 29 | def _log_event(job_id: str, message: str, level: str) -> None: |
| 30 | with SessionLocal() as session: |
| 31 | append_event(session, job_id, "log", level, str(message)) |
| 32 | session.commit() |
| 33 | |
| 34 | |
| 35 | def process_next_job() -> bool: |
no test coverage detected