inspect

etl_craft.services.operations.inspect ¶

Read-only operation documents for pipeline definitions and execution history.

list_pipelines ¶

list_pipelines(ctx: OperationContext) -> PipelineListView

List active definitions without recording a mutating action.

pipeline_graph ¶

pipeline_graph(ctx: OperationContext, pipeline_code: str) -> GraphView

Read the static graph with the pipeline's canonical definition id.

pipeline_steps ¶

pipeline_steps(ctx: OperationContext, pipeline_code: str, *, selector: RunSelector = ACTIVE_RUN) -> StepsView

Read configured tasks under the exact selected run, including tasks not yet started.

run_history ¶

run_history(ctx: OperationContext, pipeline_code: str, task_code: str | None = None, *, limit: int = 20, all_runs: bool = False, selector: RunSelector = ACTIVE_RUN) -> HistoryView

Read bounded history; selection never falls back to the most recent ended run.

audit ¶

audit(ctx: OperationContext, pipeline_code: str | None = None, *, since: datetime | None = None) -> AuditView

Read completed requests and immutable metadata captures without making an action.