|
| tuple | resubmit.parser = argparse.ArgumentParser() |
| |
| tuple | resubmit.args = parser.parse_args() |
| |
| | resubmit.timestamp = args.timestamp |
| |
| | resubmit.onePerJob = False |
| |
| tuple | resubmit.host = os.environ.get("HOSTNAME") |
| |
| | resubmit.atUCSB = False |
| |
| string | resubmit.redirector = "root://cms-xrd-global.cern.ch//" |
| |
| tuple | resubmit.bdir = os.getcwd() |
| |
| tuple | resubmit.logdir = os.path.join(bdir,'logs',timestamp) |
| |
| tuple | resubmit.arxivdir = os.path.join(bdir,'logs',timestamp,'arxiv') |
| |
| list | resubmit.loglist = [x for x in glob.glob(logdir+"/*.log")] |
| |
| tuple | resubmit.failed = set() |
| |
| tuple | resubmit.unfinished = set() |
| |
| tuple | resubmit.xrootd_err = set() |
| |
| tuple | resubmit.ferr = flog.rstrip(".log") |
| |
| tuple | resubmit.fout = flog.rstrip(".log") |
| |
| tuple | resubmit.bname = flog.split("/") |
| |
| tuple | resubmit.logfile = open(flog) |
| |
| tuple | resubmit.errfile = open(ferr) |
| |
| tuple | resubmit.user_input = raw_input('Resubmit jobs [y/N]?') |
| |
| int | resubmit.total_jobs = 0 |
| |
| tuple | resubmit.fexe = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".sh") |
| |
| tuple | resubmit.fcmd = os.path.join(logdir.replace("/logs/","/run/"), old_baby+".cmd") |
| |
| tuple | resubmit.old_exe = open(fexe) |
| |
| tuple | resubmit.new_exe = old_exe.replace("file:/hadoop/cms/phedex", redirector) |
| |
| string | resubmit.sys_cmd = "condor_submit " |
| |
| tuple | resubmit.tags = old_baby.split("_") |
| |
| tuple | resubmit.batch = int(tags[-1].strip("batch")) |
| |
| tuple | resubmit.nfiles = int(tags[-2].strip("mf")) |
| |
| tuple | resubmit.old_cmd = open(fcmd) |
| |
| list | resubmit.inputfiles = [line for line in old_exe if ("/store/" in line and "lcg-cp" not in line)] |
| |
| string | resubmit.new_baby = old_baby+"_rs" |
| |
| list | resubmit.new_exe_lines = [line for line in old_exe if ("/store/" not in line or "lcg-cp" in line)] |
| |
| tuple | resubmit.ind = new_exe_lines.index('inputFiles=\\\n') |
| |
| tuple | resubmit.new_cmd = old_cmd.replace(old_baby, new_baby) |
| |
| tuple | resubmit.fnew_cmd = fcmd.replace(old_baby,new_baby) |
| |
| tuple | resubmit.outputfile = line.split("SFN=") |
| |