|
|
|
Go to the source code of this file.
Namespaces | |
| mps_update | |
Functions | |
| def | mps_update.fill_time_info (mps_index, status, cpu_time) |
Variables | |
| mps_update.bjobs | |
| mps_update.condor_h | |
| mps_update.condor_q | |
| mps_update.cpu_time = float(match.group(1))ifmatchelse0 | |
| mps_update.cputime_regex = re.compile(r"TheCPUtimeusedis(\d+(\.\d+)?)seconds") | |
| string | mps_update.disabled = "DISABLED" |
| loop over remaining jobs to see whether they are done More... | |
| mps_update.end | |
| check for orphaned jobs More... | |
| dictionary | mps_update.htcondor_jobstatus |
| mapping of HTCondor status codes to MPS status More... | |
| mps_update.job_id = job_regex.search(line).group(1) | |
| mps_update.job_regex = re.compile(r"Job<(\d+?)>,") | |
| dictionary | mps_update.job_status = {} |
| deal with submitted jobs by looking into output of shell (bjobs/condor_q) More... | |
| mps_update.lib = mpslib.jobdatabase() | |
| collect submitted jobs (use 'in' to handle composites, e.g. More... | |
| mps_update.match = cputime_regex.search(line) | |
| mps_update.mps_index = submitted_jobs.get(job_id, -1) | |
| mps_update.results = bjobs.replace(" ","").split("-----------------------") | |
| mps_update.status = status_regex.search(line).group(1) | |
| mps_update.status_regex = re.compile(r"Status<([A-Z]+?)>") | |
| bool | mps_update.submitted = True |
| dictionary | mps_update.submitted_jobs = {} |
| string | mps_update.theBatchDirectory = "LSFJOB_" |
| mps_update.userlog = os.path.join("jobData", lib.JOBDIR[mps_index], "HTCJOB") | |
1.8.11
