29.2.36. veles.plumbing module

Created on Apr 1, 2015

Service units to change the control flow.

Copyright (c) 2013 Samsung Electronics Co., Ltd.

class EndPoint(workflow, **kwargs)[source]

Bases: veles.plumbing.UttermostPoint

Ends the pipeline execution, normally is the last unit in a workflow.

KWATTRS = {'name', 'apply_data_from_slave_threadsafe', 'view_group', 'generate_data_for_slave_threadsafe', 'timings', 'logger', 'ignore_gate'}
hide_from_registry = True
class FireStarter(workflow, **kwargs)[source]

Bases: veles.units.Unit, veles.distributable.TriviallyDistributable

Resets veles.units.Unit.stopped of the associated units exposed as veles.plumbing.FireStarter.units.

KWATTRS = {'name', 'apply_data_from_slave_threadsafe', 'view_group', 'generate_data_for_slave_threadsafe', 'timings', 'logger', 'units', 'ignore_gate'}
class Repeater(workflow, **kwargs)[source]

Bases: veles.units.TrivialUnit

Completes a typical control flow cycle, usually joining the first unit with the last one.

KWATTRS = {'name', 'apply_data_from_slave_threadsafe', 'view_group', 'generate_data_for_slave_threadsafe', 'timings', 'logger', 'ignore_gate'}
class StartPoint(workflow, **kwargs)[source]

Bases: veles.plumbing.UttermostPoint

Workflow execution normally starts from this unit.

KWATTRS = {'name', 'apply_data_from_slave_threadsafe', 'view_group', 'generate_data_for_slave_threadsafe', 'timings', 'logger', 'ignore_gate'}
hide_from_registry = True

Previous topic

29.2.35. veles.plotting_units module

Next topic

29.2.37. veles.portable module

This Page