pipelines.tasks.registry module

class pipelines.tasks.registry.TaskRegistry(module_name=None)

Bases: Registry

Registry to contain all tasks within the project.

load_task_from_id(pipeline_task: str, task_id: str, config: Dict[str, Any])

Fetches a task class from the registry and instantiates it with the provided config.

Parameters:

• pipeline_task – The property name the task is assigned to on the pipeline

• task_id – The id of the registered task class

• config – The config to create the task with