Executor#
Base class#
- class tango.executor.Executor(workspace, include_package=None, parallelism=None)[source]#
An
Executor
is a class that is responsible for running steps and caching their results.This is the base class and default implementation, registered as “default”.
Note
The
parallelism
parameter has no effect with this defaultExecutor
, but is part of the API because most subclass implementations allow configuring parallelism.- execute_step_graph(step_graph, run_name=None)[source]#
Execute a
StepGraph
. This attempts to execute every step in order. If a step fails, its dependent steps are not run, but unrelated steps are still executed. Step failures will be logged, but no exceptions will be raised.- Return type:
- class tango.executor.ExecutorOutput(successful=<factory>, failed=<factory>, not_run=<factory>)[source]#
Describes the outcome of the execution.
-
failed:
Dict
[str
,ExecutionMetadata
]# Steps that failed.
-
not_run:
Dict
[str
,ExecutionMetadata
]# Steps that were ignored (usually because of failed dependencies).
-
successful:
Dict
[str
,ExecutionMetadata
]# Steps which ran successfully or were found in the cache.
-
failed: