spreadflow_core.script module

Provides utility functions for spreadflow config script.

spreadflow_core.script.Chain(name, *procs, **kw)

Forms a chain of the given components by connecting the default input port to the default output port of its predecessor.

class spreadflow_core.script.ChainTemplate(chain=None)

Bases: spreadflow_core.script.ProcessTemplate

apply()

chain = None

component_parser = <spreadflow_core.dsl.parser.ComponentParser object>

class spreadflow_core.script.Context(origin, stack=None)

Bases: object

Utility class which simplifies construction of token streams.

classmethod pop(ctx)

Remove the ctx from the shared stack.

classmethod push(ctx)

Push the ctx onto the shared stack.

classmethod top()

Returns the topmost ctx from the stack.

spreadflow_core.script.Duplicate(port_in, **kw)

Creates a message duplicator and connects its secondary output port to the given input port.

class spreadflow_core.script.DuplicatorTemplate(destination=None)

Bases: spreadflow_core.script.ProcessTemplate

apply()

component_parser = <spreadflow_core.dsl.parser.ComponentParser object>

destination = None

exception spreadflow_core.script.NoContextError

Bases: exceptions.Exception

Raised a global context is expected but none exists.

class spreadflow_core.script.Process(alias=None, label=None, description=None, partition=None)

Bases: object

Produces a flow process from a template class or chain generator function.

component_parser = <spreadflow_core.dsl.parser.ComponentParser object>

exception spreadflow_core.script.ProcessDecoratorError

Bases: exceptions.Exception

class spreadflow_core.script.ProcessTemplate

Bases: object

apply()