Package bigjob :: Module bigjob_manager :: Class bigjob

Class bigjob

Instance Methods

__init__(self, coordination_url="advert://localhost/")
Initializes BigJob's coordination system e.g.: advert://localhost (SAGA/Advert SQLITE) advert://advert.cct.lsu.edu:8080 (SAGA/Advert POSTGRESQL) redis://localhost:6379 (Redis at localhost) tcp://localhost (ZMQ)

source code

__init_coordination(self, coordination_url)

source code

start_pilot_job(self, lrms_url, bigjob_agent_executable=None, number_nodes=1, queue=None, project=None, working_directory=None, userproxy=None, walltime=None, processes_per_node=1, filetransfers=None)
Start a batch job (using SAGA Job API) at resource manager.

source code

generate_bootstrap_script(self, coordination_host, coordination_namespace)

source code

escape_rsl(self, bootstrap_script)

source code

escape_pbs(self, bootstrap_script)

source code

escape_ssh(self, bootstrap_script)

source code

escape_bliss(self, bootstrap_script)

source code

add_subjob(self, jd, job_url, job_id)

source code

delete_subjob(self, job_url)

source code

get_subjob_state(self, job_url)

source code

get_subjob_details(self, job_url)

source code

get_state(self)
duck typing for get_state of saga.job.job state of saga job that is used to spawn the pilot agent

source code

get_state_detail(self)
internal state of BigJob agent

source code

get_free_nodes(self)

source code

stop_pilot_job(self)
mark in advert directory of pilot-job as stopped

source code

cancel(self)
duck typing for cancel of saga.cpr.job and saga.job.job

source code

__parse_url(self, url)

source code

__get_bigjob_working_dir(self)

source code

__get_subjob_working_dir(self, sj_id)

source code

__stage_files(self, filetransfers, target_url)

source code

__third_party_transfer(self, source_url, target_url)
Transfers from source URL to machine of PS (target path)

source code

__create_remote_directory(self, target_url)

source code

__print_traceback(self)

source code

__repr__(self)
repr(x)

source code

__del__(self)

source code

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, coordination_url="advert://localhost/")
(Constructor)

source code

Initializes BigJob's coordination system e.g.: advert://localhost (SAGA/Advert SQLITE) advert://advert.cct.lsu.edu:8080 (SAGA/Advert POSTGRESQL) redis://localhost:6379 (Redis at localhost) tcp://localhost (ZMQ)

Overrides: object.__init__

start_pilot_job(self, lrms_url, bigjob_agent_executable=None, number_nodes=1, queue=None, project=None, working_directory=None, userproxy=None, walltime=None, processes_per_node=1, filetransfers=None)

source code

Start a batch job (using SAGA Job API) at resource manager. Currently, the following resource manager are supported: fork://localhost/ (Default Job Adaptor gram://qb1.loni.org/jobmanager-pbs (Globus Adaptor) pbspro://localhost (PBS Prop Adaptor)