Skip to content

Branching step

Common utilities for composite steps with named branches.

Author

Kadek Denaya (kadek.d.r.diana@gdplabs.id)

References

NONE

BranchingStep(name, retry_config=None, error_handler=None, cache_store=None, cache_config=None)

Bases: BaseCompositeStep

Mixin-like base for composites that maintain named branches.

Attributes:

Name Type Description
branches dict[str, PipelineSteps]

The branches to execute in parallel.

Initialize the composite step.

Parameters:

Name Type Description Default
name str

A unique identifier for the pipeline step.

required
retry_config RetryConfig | None

Configuration for retry behavior. Defaults to None.

None
error_handler BaseStepErrorHandler | None

Strategy to handle errors during execution.

None
cache_store 'BaseCache' | None

Cache store to be used for caching. Defaults to None, in which case no cache store is used.

None
cache_config dict[str, Any] | None

Cache configuration to be used for caching. Defaults to None, in which case no cache configuration is used.

None

apply_exclusions(exclusions)

Apply exclusions to this branching step and its children.

Marks self excluded, lets subclass perform internal structural changes, then propagates exclusions to children per branch.

Parameters:

Name Type Description Default
exclusions ExclusionSet

The exclusion set to apply.

required