task Module

class pipelet.task.Task(seg, task_input=[], status=None, task_output=[], id=None, queued_on=None, parents=[], str_input=None)

A segment code associated with its input/output product(s).

A task is the association of a segment with its input product, its execution status and its output product(s).

store_meta(fn)

Store meta information for task.

This is used to rebuild db.

update_status(status)

Update task status.

class pipelet.task.TaskList

List of accomplished tasks per segment.

multiplex(seg, parent_list, directive)

Compute the result of a multiplex directive

Multiplex method is one of ‘cross_prod’, ‘union’, ‘zip’.

pop(seg)

Remove and return stored products of a segment.

push(t)

Add a task to the task list.