mps_update Namespace Reference

Functions
def	fill_time_info

Variables
tuple	condor_h
tuple	condor_q
string	disabled = "DISABLED"
dictionary	htcondor_jobstatus
	mapping of HTCondor status codes to MPS status More...
dictionary	job_status = {}
	deal with submitted jobs by looking into output of shell (condor_q) More...
tuple	lib = mpslib.jobdatabase()
	collect submitted jobs (use 'in' to handle composites, e.g. More...
tuple	mps_index = submitted_jobs.get(job_id, -1)
list	status = htcondor_jobstatus[status]
	submitted = True
dictionary	submitted_jobs = {}
dictionary	submitted_jobs_copy = { k:v for k,v in submitted_jobs.items() }
	loop over remaining jobs to see whether they are done More...
tuple	userlog = os.path.join("jobData", lib.JOBDIR[mps_index], "HTCJOB")

Function Documentation

def mps_update.fill_time_info	(		mps_index,
			status,
			cpu_time
	)

Fill timing info in the database for `mps_index`.

Arguments:
- `mps_index`: index in the MPS database
- `status`: job status
- `cpu_time`: extracted CPU timing information

Definition at line 10 of file mps_update.py.

References str.

def fill_time_info(mps_index, status, cpu_time):
    """Fill timing info in the database for `mps_index`.

    Arguments:
    - `mps_index`: index in the MPS database
    - `status`: job status
    - `cpu_time`: extracted CPU timing information
    """

    cpu_time = int(round(cpu_time))  # care only about seconds for now
    if status in ("RUN", "DONE"):
        if cpu_time > 0:
            diff = cpu_time - lib.JOBRUNTIME[mps_index]
            lib.JOBRUNTIME[mps_index] = cpu_time
            lib.JOBHOST[mps_index] = "+"+str(diff)
            lib.JOBINCR[mps_index] = diff
        else:
            lib.JOBRUNTIME[mps_index] = 0
            lib.JOBINCR[mps_index] = 0