runs
etl_craft.services.operations.runs ¶
Run lifecycle operations and execution-request dispatch.
trigger_run ¶
trigger_run(ctx: OperationContext, pipeline_code: str, *, run_date: date | None = None, reason: str | None = None, force: bool = False, init_only: bool = False, selector: RunSelector = ACTIVE_RUN) -> OperationResult
Run or resume a pipeline and return its exact stored state.
initialize_run ¶
initialize_run(ctx: OperationContext, pipeline_code: str, *, run_date: date | None = None, selector: RunSelector = ACTIVE_RUN) -> OperationResult
Initialize or resume a run without running its tasks.
finalize_run ¶
finalize_run(ctx: OperationContext, pipeline_code: str, *, selector: RunSelector = ACTIVE_RUN, run_date: date | None = None) -> OperationResult
Finalize the selected run from its task summaries.
skip_run ¶
Create a skipped run without running any task.
mark_run ¶
mark_run(ctx: OperationContext, pipeline_code: str, status: str, reason: str, *, selector: RunSelector = ACTIVE_RUN) -> OperationResult
Mark the selected run independently of the marked status.
stand_in_run ¶
stand_in_run(ctx: OperationContext, pipeline_code: str, status: str, reason: str, *, task_code: str | None = None, rows: int | None = None) -> OperationResult
Record a stand-in run and optionally its stand-in task.
cancel_run ¶
cancel_run(ctx: OperationContext, pipeline_code: str, reason: str, *, selector: RunSelector = ACTIVE_RUN) -> OperationResult
Cancel the exact selected run using the existing process and lease guards.
reconcile_runs ¶
reconcile_runs(ctx: OperationContext, pipeline_code: str | None = None, task_code: str | None = None) -> ReconciliationView
Fence expired owners, optionally within one pipeline or task.
execute_run ¶
Dispatch one validated request without CLI argument objects.
mark ¶
mark(ctx: OperationContext, pipeline_code: str, status: str, reason: str, *, task_code: str | None = None, rows: int | None = None, stale: bool = False, new_run: bool = False, selector: RunSelector = ACTIVE_RUN) -> OperationResult
Mark a task, a run, or a new stand-in run with one request audit.