Class AMSWorkflowManager¶

Defined in File wf_manager.py

Class Documentation¶

class AMSWorkflowManager¶

@brief Manages all job submissions of the current execution.

Public Functions

__init__(self, str rmq_config, str db_dir, str application_name, url, JobList domain_jobs, JobList stage_jobs, JobList sub_select_jobs, JobList train_jobs)¶

rmq_config(self)¶

__str__(self)¶

broadcast_train_specs(self, rmq_config)¶

stager_done_cb(self, future)¶

domain_jobid_cb(self, future)¶

domain_done_cb(self, future)¶

start_domain(self, store, rmq_config, domain_uri, rmq_stage_poller)¶

start_stagers(self, store, rmq_config, domain_uri, stage_uri, orchestrator_publisher, rmq_stage_poller)¶

start(self, domain_uri, stage_uri, ml_uri)¶

from_descr(cls, str json_file, Optional[str] rmq_config=None)¶

Public Members

jobs¶

Protected Attributes

_rmq_config¶

_db_dir¶

_url¶

_application_name¶

_domain_jobs¶

_stage_jobs¶

_sub_select_jobs¶

_train_jobs¶