palgen.machinery.pipeline

Module Contents

palgen.machinery.pipeline.Step

palgen.machinery.pipeline.get_name(obj)

class palgen.machinery.pipeline.PipelineMeta

__slots__ = ()

__rshift__(step)

Parameters:

step (Step | Type[Pipeline] | Any) –

Return type:

Pipeline

class palgen.machinery.pipeline.Task(steps=None, max_jobs=0)

Parameters:

• steps (Optional[list[Step]]) –

• max_jobs (int) –

__slots__ = ('max_jobs', 'steps')

append(step)

Return type:

None

__str__()

Return str(self).

Return type:

str

__repr__()

Return repr(self).

Return type:

str

__bool__()

Return type:

bool

class palgen.machinery.pipeline.Pipeline(state=None)

__slots__ = ('initial_state', 'tasks')

run

__str__

__rshift__(step)

Parameters:

step (Step | Type[Pipeline] | Any) –

Return type:

Pipeline

__iter__(state=None, obj=None)

Parameters:

• state (Optional[Iterable]) –

• obj (Any) –

__call__(state, obj=None, max_jobs=None)

Parameters:

• state (list[Any]) –

• obj (Any) –

• max_jobs (Optional[int]) –

__repr__()

Return repr(self).