pyre.flow

Package Contents

class pyre.flow.producer

Bases: pyre.protocol

The requirements that all factories must implement

make(self, **kwds)

Build all products

plan(self, **kwds)

Describe what needs to get to done to make the products

class pyre.flow.specification

Bases: pyre.protocol

The protocol of product specifications

Specifications are snapshots of product attributes

input = False
output = False
class pyre.flow.factory

Bases: pyre.flow.Node.Node

The base class for creators of data products

make(self, context=None)

Construct my products

plan(self, context=None)

Describe what needs to get to done to make my products

class pyre.flow.product

Bases: pyre.flow.Node.Node

The base class for data products

sync(self)

Examine my state

class pyre.flow.bind(method, inputs=None, outputs=None, **kwds)

Method decorator that constructs {operator} nodes to connect {inputs} to {outputs}

method
inputs
outputs
__get__(self, instance, cls)

Access to the method

class pyre.flow.workflow

Bases: pyre.application

A simple application class for managing workflows

factories
doc = the set of flow factories
products
doc = the set of flow products