juturna.components.exceptions package

Module contents

exception juturna.components.exceptions.PipelineAlreadyRunningError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when warmup() is called on a pipeline that is running.

exception juturna.components.exceptions.PipelineBusyError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when a lifecycle operation is called while another one is already in progress on the same pipeline.

Only one of warmup()/start()/stop()/destroy() can be claimed at a time: the transition in flight owns the pipeline’s internal state (nodes, DAG, node threads) until it completes, so a concurrent call cannot be safely evaluated against the pipeline’s current status.

exception juturna.components.exceptions.PipelineDestroyedError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when a lifecycle operation is called on a destroyed pipeline.

destroy() itself is exempted: calling it on an already destroyed pipeline is a no-op.

exception juturna.components.exceptions.PipelineNotReadyError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when start() is called before the pipeline was warmed up.

exception juturna.components.exceptions.PipelineNotRunningError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when stop() is called on a pipeline that is not running.

exception juturna.components.exceptions.PipelineStateError(pipeline_name: str, message: str)

Bases: RuntimeError

Base exception for illegal Pipeline lifecycle transitions.

exception juturna.components.exceptions.PipelineStoppedError(pipeline_name: str, message: str)

Bases: PipelineStateError

Raised when warmup() or start() is called on a stopped pipeline.

A stopped pipeline cannot be resumed: it must be destroyed and a new pipeline created in its place.