Class AMSFluxExecutor¶
Defined in File ams_flux.py
Inheritance Relationships¶
Base Type¶
public FluxExecutor
Derived Type¶
public ams_flux.AMSFluxOrchestratorExecutor(Class AMSFluxOrchestratorExecutor)
Class Documentation¶
- ams_flux.AMSFluxExecutor : public FluxExecutor
A Flux executor that submits jobs to the provided uri. The executor extends the original FluxExecutor as it generates "AMSFluxExecutorFuture" 's that can track the uri of nested jobs. This is required when 'partitioning' an allocation to sub allocations and issuing 'nested' commands
Subclassed by ams_flux.AMSFluxOrchestratorExecutor
Public Functions
- __init__(self, track_uri, *args, **kwargs)¶
- shutdown_event(self)¶
The _shutdown_event property.
Protected Functions
- _create_future(self, factory, *factory_args)¶