Class AMSOrchestratorJob¶
Defined in File ams_jobs.py
Inheritance Relationships¶
Base Type¶
public ams_jobs.AMSJob(Class AMSJob)
Class Documentation¶
- ams_jobs.AMSOrchestratorJob : public ams_jobs.AMSJob
A JOB to be scheduled "somewhere" that can schedule jobs "somewhere" else. Currently this is tested only when the orchestrator schedules jobs within the same job-allocation
Public Functions
- __init__(self, flux_uri, rmq_config)¶
Attaches a callable that will be called when the future finishes. :param name: An arbitary name for every job. This can be an arbitary string. :param executable: A string pointing to the executable to be executed :param environ: The environment to be used when scheduling the job. :param resources: The resources dedicated to this job. :param stdout File to redirect the stdout. :param stderr File to redirect the stderr. :param ams_log: A boolean value to enable the logging of AMS printouts :param is_mpi: Whether the job is an mpi job. :param cli_args: positional arguments of the cli command :param cli_kwargs: key-word arguments of the cli command :return: ``self``