Class AMSFluxOrchestratorExecutor¶
Defined in File ams_flux.py
Inheritance Relationships¶
Base Type¶
public ams_flux.AMSFluxExecutor(Class AMSFluxExecutor)
Class Documentation¶
- ams_flux.AMSFluxOrchestratorExecutor : public ams_flux.AMSFluxExecutor
Public Functions
- __init__(self, o_queue, domains, *args, **kwargs)¶
- submit(self, domain, *args, **kwargs)¶
Submit a jobspec to Flux and return a ``FluxExecutorFuture``. Accepts the same positional and keyword arguments as ``flux.job.submit``, except for the ``flux.job.submit`` function's first argument, ``flux_handle`` and instead accepts the ``domain`` argument pointing to the domain currently being scheduled by AMS. :param domain: AMSDomain training job description :param jobspec: jobspec defining the job request :type jobspec: Jobspec or its string encoding :param urgency: job urgency 0 (lowest) through 31 (highest) (default is 16). Priorities 0 through 15 are restricted to the instance owner. :type urgency: int :param waitable: allow result to be fetched with ``flux.job.wait()`` (default is False). Waitable=True is restricted to the instance owner. :type waitable: bool :param debug: enable job manager debugging events to job eventlog (default is False) :type debug: bool :param pre_signed: jobspec argument is already signed (default is False) :type pre_signed: bool :raises RuntimeError: if ``shutdown`` has been called or if an error has occurred and new jobs cannot be submitted (e.g. a remote Flux instance can no longer be communicated with).
- get_o_queue(self)¶
- domains(self)¶
Protected Functions
- _create_future(self, domain, factory, *factory_args)¶