Class TrainJobScheduler¶

Defined in File orchestrator.py

Class Documentation¶

class TrainJobScheduler¶

@brief a dataflow step that accepts (eventually) requests from the 'RequestProcessor'
    to schedule jobs in an existing flux instance. A job in the context of the AMSFluxOrchestratorExecutor
    is the pair of sub-selection job and a training job.

Public Functions

__init__(self, str flux_uri, Queue i_queue, Queue o_queue, AvailableDomains domains, fake_flux=False)¶

__call__(self)¶

Public Members

i_queue¶

o_queue¶

Protected Functions

_schedule(self, executor, str domain_name)¶

_run(self, executor)¶

_local_run(self)¶

_flux_run(self)¶

Protected Attributes

_flux_uri¶

_domains¶

_fake_flux¶