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 default Executor, 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

ExecutorOutput

execute_sub_graph_for_step(step_graph, step_name, run_name=None)[source]#

Execute the sub-graph associated with a particular step in a StepGraph.

Return type

None