Class AMSNetworkStageJob

Inheritance Relationships

Base Type

Class Documentation

ams_jobs.AMSNetworkStageJob : public ams_jobs.AMSStageJob
A job description for transfering data from the application to the database reading using rmq server-client protocol.
This class represents the consumer part of the transactions.

Public Functions

__init__(self, Union[Dict[str, Union[str, int]], AMSJobResources] resources, str dest, str url, str application_name, str creds, str db_type="dhdf5", bool update_models=False, Optional[str] prune_module_path=None, Optional[str] prune_class=None, Optional[Mapping[str, str]] environ=None, Optional[str] stdout=None, Optional[str] stderr=None, List[str] cli_args=[], Mapping[str, str] cli_kwargs={})
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``
from_descr(cls, descr, dest, url, application_name, creds, resources)