add_task

caput.pipeline.Manager.add_task(task, task_spec={}, **kwargs)

Add a task instance to the pipeline.

Parameters:

taskTask

A pipeline task instance.

task_specdict

include optional argument: requires, in_, out : list or string The names of the task inputs and outputs.

**kwargsAny

Included for legacy purposes. Alternative method to provide requires, in_, and out arguments. These should only be provided if task_spec is not provided - a ValueError will be raised otherwise.

Raises:

CaputConfigError

If there was an error in the task configuration.