Function
append_event
(
session: Session,
job_id: str,
event_type: str,
level: str,
message: str,
payload: Optional[dict] = None,
)
Source from the content-addressed store, hash-verified
| 29 | |
| 30 | |
| 31 | def append_event( |
| 32 | session: Session, |
| 33 | job_id: str, |
| 34 | event_type: str, |
| 35 | level: str, |
| 36 | message: str, |
| 37 | payload: Optional[dict] = None, |
| 38 | ) -> GenerationEvent: |
| 39 | event = GenerationEvent( |
| 40 | job_id=job_id, |
| 41 | event_type=event_type, |
| 42 | level=level, |
| 43 | message=message, |
| 44 | payload=payload, |
| 45 | ) |
| 46 | session.add(event) |
| 47 | session.flush() |
| 48 | return event |
| 49 | |
| 50 | |
| 51 | def get_job(session: Session, job_id: str) -> Optional[GenerationJob]: |