Class AMSFakeFluxOrchestatorExecutor¶
Defined in File ams_flux.py
Inheritance Relationships¶
Base Type¶
public ThreadPoolExecutor
Class Documentation¶
- ams_flux.AMSFakeFluxOrchestatorExecutor : public ThreadPoolExecutor
A class to emulate a FluxExecutor with subprocesses. For every job being submitted instead of running it with flux job submission we use subprocess to run a single instantiation of the job.
Public Functions
- __init__(self, Queue o_queue, domains, *args, **kwargs)¶
- submit(self, domain, job_spec)¶
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``. :param domain: AMSDomain training job description :param jobspec: jobspec defining the job request :type jobspec: Jobspec or its string encoding :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)¶
- get_domains(self)¶