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”.


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


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