SAService Architect Back to designer
SAService ArchitectDocumentation
Python DSLAPI: Core Objects
Python API reference source >> target | target << source | source.link(target, ...)

Stream and Link objects

Runtime graph nodes and optional persisted execution metadata for an existing edge.

When to use

Keep returned Stream objects in variables so graph wiring and explicit link options remain readable.

Behavior

  • >> sets a primary source and returns the target, allowing chains.
  • << appends an additional source and returns the target, allowing merge chains.
  • from_sources(*sources) replaces a complete multi-source list.
  • link(target, ...) delegates registration to the owning Service and returns Link.

Stream fields properties

Normally populated by Pipeline factories.

PropertyTypeDescription
key / name / typestr

Stable symbolic identity, display name, and selected transformation.

service / pipelineService / Pipeline

Immutable graph ownership context.

source / sourcesStream | list[Stream]

Primary and additional incoming graph references.

endpoint / functionEndpoint | Function | None

Boundary or callback metadata when supported.

x / yfloat

Designer coordinates.

Python example

incoming >> validate >> publish
merge << cache_result << database_result

validate.link(
    publish,
    call_semantics=CallSemantics.PRIORITY_TASK_POOL,
    pool=workers,
    priority=5,
)