yenta.tasks package

Submodules

yenta.tasks.Task module

exception yenta.tasks.Task.InvalidTaskDefinitionError

Bases: Exception

class yenta.tasks.Task.ParameterSpec(param_name: str, param_type: yenta.tasks.Task.ParameterType, result_spec: Union[yenta.tasks.Task.ResultSpec, NoneType] = None, selector: Union[Callable, NoneType] = None)

Bases: object

result_spec = None

selector = None

class yenta.tasks.Task.ParameterType

Bases: int, enum.Enum

An enumeration.

EXPLICIT = 2

PIPELINE_RESULTS = 1

class yenta.tasks.Task.ResultSpec(result_task_name: str, result_var_name: Union[str, NoneType] = None)

Bases: object

result_var_name = None

class yenta.tasks.Task.ResultType

Bases: str, enum.Enum

An enumeration.

ARTIFACT = 'artifacts'

VALUE = 'values'

class yenta.tasks.Task.TaskDef(name: str, depends_on: Union[List[str], NoneType], pure: bool, param_specs: List[yenta.tasks.Task.ParameterSpec] = <factory>)

Bases: object

yenta.tasks.Task.build_parameter_spec(func, depends_on: List[str])

yenta.tasks.Task.task(_func=None, *, depends_on: Optional[List[str]] = None, pure: bool = True, selectors=None)

Module contents