nirs4all.pipeline.dagml.cancellation module

Invocation-scoped cooperative cancellation at scientific task boundaries.

exception nirs4all.pipeline.dagml.cancellation.DagRunCancelled[source]

Bases: RuntimeError

The caller cancelled a DAG run before its next scientific task.

nirs4all.pipeline.dagml.cancellation.check_cancellation() → None[source]: Never retry or publish a cancelled run as completed.