Python DSL reference source >> target | target << source | source.link(target, ...)

Stream connections and links

Build graph relationships directly between Stream objects and add persisted delivery settings only when they differ from service defaults.

When to use

Use operators for every graph edge; call Stream.link() only for explicit execution semantics.

source >> target assigns the target primary source.
target << source appends a source to a multi-input operator.
target.from_sources(a, b, c) replaces the complete multi-source list.
source.link(target, ...) registers delivery properties on an edge that already exists.
If link semantics equal the service default, the YAML-to-Python importer omits the redundant link call.

Persisted execution settings.

PropertyTypeDescription

call_semanticsCallSemantics

FunctionCall, TaskPool, PriorityTaskPool, ParallelCall, or Inherited.

async_boolean

Asynchronous FunctionCall behavior where supported.

poolPool

Registered task-pool object; serialized as poolName.

priorityinteger

Priority used by PriorityTaskPool.

split >> process

split.link(
    process,
    call_semantics=CallSemantics.PRIORITY_TASK_POOL,
    pool=workers,
    priority=7,
)