mps_fire Namespace Reference

Functions
def	forward_proxy
def	write_HTCondor_submit_file_mille
def	write_HTCondor_submit_file_pede

Variables
string	action = "store_true"
tuple	args = parser.parse_args(sys.argv[1:])
tuple	backupCfgPath = os.path.join(Path, mergeCfg+".bak")
tuple	backupScriptPath = os.path.join(Path, "theScript.sh.bak")
tuple	cfgPath = os.path.join(Path, mergeCfg)
string	command = 'cat '
string	curJobName = 'm'
tuple	dircontents = os.listdir(Path)
	fire_htcondor = False
string	help = "number of Mille jobs to be submitted (default: %(default)d)"
	i = lib.nJobs
string	inCfgPath = theJobData+'/'
	invalid_id = False
	job_mask = lib.JOBDIR
tuple	job_submit_file = write_HTCondor_submit_file_mille(Path, scriptPath, lib,os.path.join(Path,".user_proxy"))
int	jobNumFrom1 = i+1
tuple	lib = mpslib.jobdatabase()
tuple	match = re.search(r"1 job\(s\) submitted to cluster (\d+)\.", result)
tuple	mergeCfg = subprocess.check_output(command, stderr=subprocess.STDOUT, shell=True)
	mergeOK = True
	nMerge = i-lib.nJobs
int	nSub = 0
tuple	parser
tuple	Path = os.path.join(theJobData,lib.JOBDIR[i])
tuple	resources = lib.get_class('mille')
tuple	result
tuple	schedinfo = subprocess.check_output(["myschedd","show"])
tuple	scriptPath = os.path.join(Path, "theScript.sh")
string	submission = "condor_submit -batch-name %s %s"
tuple	theJobData = os.path.join(os.getcwd(), "jobData")
string	theJobName = 'mpalign'
tuple	weight_conf = cPickle.load(f)

Function Documentation

def mps_fire.forward_proxy

(

rundir

)

Forward proxy to location visible from the batch system.

Arguments:
- `rundir`: directory for storing the forwarded proxy

Definition at line 31 of file mps_fire.py.

References edm.decode(), print(), and digitizers_cfi.strip.

def forward_proxy(rundir):
    """Forward proxy to location visible from the batch system.

    Arguments:
    - `rundir`: directory for storing the forwarded proxy
    """

    if not mps_tools.check_proxy():
        print("Please create proxy via 'voms-proxy-init -voms cms -rfc'.")
        sys.exit(1)

    local_proxy = subprocess.check_output(["voms-proxy-info", "--path"]).decode().strip()
    shutil.copyfile(local_proxy, os.path.join(rundir,".user_proxy"))