arc#
ARC contrib functionality.
Class ARCWorkflow
#
- class ARCWorkflow(*args, **kwargs)#
Bases:
BaseRemoteWorkflow
- workflow_proxy_cls#
alias of
ARCWorkflowProxy
Class ARCJobManager
#
- class ARCJobManager(job_list=None, ce=None, threads=1)#
Bases:
BaseJobManager
- submit(job_file, job_list=None, ce=None, retries=0, retry_delay=3, silent=False)#
Abstract atomic or group job submission. Can throw exceptions. Should return a list of job ids.
- cancel(job_id, job_list=None, silent=False)#
Abstract atomic or group job cancellation. Can throw exceptions. Should return a dictionary mapping job ids to per-job return values.
- cleanup(job_id, job_list=None, silent=False)#
Abstract atomic or group job cleanup. Can throw exceptions. Should return a dictionary mapping job ids to per-job return values.
- query(job_id, job_list=None, silent=False)#
Abstract atomic or group job status query. Can throw exceptions. Should return a dictionary mapping job ids to per-job return values.
Class ARCJobFileFactory
#
- class ARCJobFileFactory(file_name='arc_job.xrsl', command=None, executable=None, arguments=None, input_files=None, output_files=None, postfix_output_files=True, output_uri=None, overwrite_output_files=True, job_name=None, log='log.txt', stdout='stdout.txt', stderr='stderr.txt', custom_content=None, absolute_paths=True, **kwargs)#
Bases:
BaseJobFileFactory
- create(postfix=None, **kwargs)#
Abstract job file creation method that must be implemented by inheriting classes.