spdl.pipeline.defs.Merge

Merge(pipeline_configs: Sequence[PipelineConfig[Any, Any]]) → MergeConfig[Any]

Create a MergeConfig.

Merge multiple pipelines into one output queue.

Parameters:

• pipeline_configs – A list of pipeline configs.

• name – The name (prefix) to give to the task.

Returns:

The config object.

See also

Example: Pipeline definitions

Illustrates how to build a complex pipeline.