Ctrl+K

glite

glite#

gLite contrib functionality.

Class GLiteWorkflow#

class GLiteWorkflow(*args, **kwargs)#

Bases: BaseRemoteWorkflow

workflow_proxy_cls#

alias of GLiteWorkflowProxy

Class GLiteJobManager#

class GLiteJobManager(ce=None, delegation_id=None, threads=1)#

Bases: BaseJobManager

submit(job_file, ce=None, delegation_id=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, 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, 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, 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 GLiteJobFileFactory#

class GLiteJobFileFactory(file_name='glite_job.jdl', command=None, executable=None, arguments=None, input_files=None, output_files=None, postfix_output_files=True, output_uri=None, stdout='stdout.txt', stderr='stderr.txt', vo=None, custom_content=None, absolute_paths=False, **kwargs)#

Bases: BaseJobFileFactory

create(postfix=None, render_variables=None, **kwargs)#

Abstract job file creation method that must be implemented by inheriting classes.

Contents