backend/workers/pipeline_worker.py
| Symbol | Kind | Source line |
|---|---|---|
BlockedByPredecessor |
ClassDef | L35 |
_PipelineDbLogHandler |
ClassDef | L73 |
_PipelineDbLogHandler.__init__ |
FunctionDef | L74 |
_PipelineDbLogHandler.emit |
FunctionDef | L78 |
_emit_progress_event |
AsyncFunctionDef | L99 |
_stall_watchdog |
AsyncFunctionDef | L120 |
_cancel_watchdog |
AsyncFunctionDef | L175 |
_flush_job_logs_to_db |
AsyncFunctionDef | L232 |
_job_log_streamer |
AsyncFunctionDef | L267 |
_worker_id |
FunctionDef | L284 |
_handle_noop |
AsyncFunctionDef | L290 |
_dispatch |
AsyncFunctionDef | L294 |
_heartbeat_loop |
AsyncFunctionDef | L300 |
_run_loop |
AsyncFunctionDef | L326 |
_run_loop._iso_utc_after |
FunctionDef | L347 |
_run_loop._block_if_predecessor_not_ready |
AsyncFunctionDef | L350 |
_run_loop._process_one |
AsyncFunctionDef | L422 |
main |
FunctionDef | L746 |