Functions | |
def | remove_cron (cronid) |
def | send_email (FROM, TO, SUBJECT, MESSAGE, server, quitserver=True) |
Variables | |
file | |
dictionary | tsdic |
string | description |
parser = argparse.ArgumentParser(description=description) | |
action | |
version | |
help | |
opts = parser.parse_args() | |
inifile = opts.inifile | |
bool | startcron = False |
string | cronid = "knopeJob" |
cp = RawConfigParser() | |
runconfig | |
keytab = None | |
certificate = cp.get("kerberos", "certificate") | |
authprinc = cp.get("kerberos", "auth_princ") | |
cprun = RawConfigParser() | |
timestep = cp.get("times", "steps") | |
string | errmsg = "Error... 'steps' value in '[times'] must be 'hourly', 'daily', 'weekly' or 'monthly'" |
email = None | |
server = None | |
FROM = None | |
HOST = socket.getfqdn() | |
USER = os.environ["USER"] | |
now = Time.now() | |
gpsnow = int(now.replicate("gps").value) | |
prevdags = None | |
rescuedags = None | |
rundir | |
string | subject = sys.argv[0] + ": Error message" |
string | lockfile = prevdags[-1] + ".lock" |
cron = CronTab(user=True) | |
thisjob = job | |
t1 = Time("2010-01-01 00:00:00") | |
t2 = Time("2010-01-02 00:00:00") | |
dt = t2 - t1 | |
newcrontime = now + dt | |
Nrescues = rescuedags[prevdags[-1]] | |
string | rescuefile = prevdags[-1] + ".rescue" |
x = Popen(["condor_submit_dag", prevdags[-1]]) | |
fc = open(inifile, "w") | |
starttime = cp.getint("times", "starttime") | |
endtime = cp.getint("times", "endtime") | |
timelag = cp.getint("times", "lag") | |
prev_ends = ast.literal_eval(cp.get("times", "previous_endtimes")) | |
newstart = prev_ends[-1] | |
newend = newstart + int(tsdic[timestep]) | |
runscript = cp.get("configuration", "exec") | |
string | dagname = "automated_run_%s-%s" % (str(newstart), str(newend)) |
string | wov = "" |
virtualenv = cp.get("configuration", "virtualenv") | |
woh = os.environ["WORKON_HOME"] | |
profile = None | |
string | krbcert = "export KRB5CCNAME={}".format(certificate) |
string | kinit = "/usr/bin/kinit -a -P -F -k -t {} {}".format(keytab, authprinc) |
string | ligoproxyinit = "/usr/bin/ligo-proxy-init -k" |
string | cronwrapperscript = os.path.splitext(inifile)[0] + ".sh" |
tuple | cronwrapper |
fp = open(cronwrapperscript, "w") | |
job = cron.new(command=cronwrapperscript, comment=cronid) | |
day = now.datetime.day | |
month = now.datetime.month | |
year = now.datetime.year | |
hour = now.datetime.hour | |
minute = now.datetime.minute | |
dow = now.datetime.strftime("%a").upper() | |
p = sp.Popen("{0} {1}".format(runscript, runconfig), shell=True) | |
RUN ANALYSIS SCRIPT ###. More... | |
out | |
err | |
def lalpulsar_knope_automation_script.remove_cron | ( | cronid | ) |
Definition at line 66 of file lalpulsar_knope_automation_script.py.
def lalpulsar_knope_automation_script.send_email | ( | FROM, | |
TO, | |||
SUBJECT, | |||
MESSAGE, | |||
server, | |||
quitserver = True |
|||
) |
Definition at line 78 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.file |
Definition at line 34 of file lalpulsar_knope_automation_script.py.
dictionary lalpulsar_knope_automation_script.tsdic |
Definition at line 56 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.description |
Definition at line 94 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.parser = argparse.ArgumentParser(description=description) |
Definition at line 98 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.action |
Definition at line 99 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.version |
Definition at line 99 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.help |
Definition at line 100 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.opts = parser.parse_args() |
Definition at line 103 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.inifile = opts.inifile |
Definition at line 105 of file lalpulsar_knope_automation_script.py.
bool lalpulsar_knope_automation_script.startcron = False |
Definition at line 115 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.cronid = "knopeJob" |
Definition at line 116 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.cp = RawConfigParser() |
Definition at line 119 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.runconfig |
Definition at line 136 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.keytab = None |
Definition at line 159 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.certificate = cp.get("kerberos", "certificate") |
Definition at line 164 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.authprinc = cp.get("kerberos", "auth_princ") |
Definition at line 167 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.cprun = RawConfigParser() |
Definition at line 173 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.timestep = cp.get("times", "steps") |
Definition at line 182 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.errmsg = "Error... 'steps' value in '[times'] must be 'hourly', 'daily', 'weekly' or 'monthly'" |
Definition at line 185 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.email = None |
Definition at line 194 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.server = None |
Definition at line 195 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.FROM = None |
Definition at line 221 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.HOST = socket.getfqdn() |
Definition at line 224 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.USER = os.environ["USER"] |
Definition at line 225 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.now = Time.now() |
Definition at line 231 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.gpsnow = int(now.replicate("gps").value) |
Definition at line 232 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.prevdags = None |
Definition at line 235 of file lalpulsar_knope_automation_script.py.
dictionary lalpulsar_knope_automation_script.rescuedags = None |
Definition at line 236 of file lalpulsar_knope_automation_script.py.
tuple lalpulsar_knope_automation_script.rundir |
Definition at line 238 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.subject = sys.argv[0] + ": Error message" |
Definition at line 253 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.lockfile = prevdags[-1] + ".lock" |
Definition at line 258 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.cron = CronTab(user=True) |
Definition at line 272 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.thisjob = job |
Definition at line 274 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.t1 = Time("2010-01-01 00:00:00") |
Definition at line 277 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.t2 = Time("2010-01-02 00:00:00") |
Definition at line 278 of file lalpulsar_knope_automation_script.py.
Definition at line 279 of file lalpulsar_knope_automation_script.py.
Definition at line 280 of file lalpulsar_knope_automation_script.py.
int lalpulsar_knope_automation_script.Nrescues = rescuedags[prevdags[-1]] |
Definition at line 307 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.rescuefile = prevdags[-1] + ".rescue" |
Definition at line 313 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.x = Popen(["condor_submit_dag", prevdags[-1]]) |
Definition at line 335 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.fc = open(inifile, "w") |
Definition at line 352 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.starttime = cp.getint("times", "starttime") |
Definition at line 401 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.endtime = cp.getint("times", "endtime") |
Definition at line 426 of file lalpulsar_knope_automation_script.py.
int lalpulsar_knope_automation_script.timelag = cp.getint("times", "lag") |
Definition at line 450 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.prev_ends = ast.literal_eval(cp.get("times", "previous_endtimes")) |
Definition at line 459 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.newstart = prev_ends[-1] |
Definition at line 471 of file lalpulsar_knope_automation_script.py.
Definition at line 478 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.runscript = cp.get("configuration", "exec") |
Definition at line 510 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.dagname = "automated_run_%s-%s" % (str(newstart), str(newend)) |
Definition at line 542 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.wov = "" |
Definition at line 585 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.virtualenv = cp.get("configuration", "virtualenv") |
Definition at line 589 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.woh = os.environ["WORKON_HOME"] |
Definition at line 591 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.profile = None |
Definition at line 611 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.krbcert = "export KRB5CCNAME={}".format(certificate) |
Definition at line 622 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.kinit = "/usr/bin/kinit -a -P -F -k -t {} {}".format(keytab, authprinc) |
Definition at line 623 of file lalpulsar_knope_automation_script.py.
Definition at line 624 of file lalpulsar_knope_automation_script.py.
string lalpulsar_knope_automation_script.cronwrapperscript = os.path.splitext(inifile)[0] + ".sh" |
Definition at line 633 of file lalpulsar_knope_automation_script.py.
tuple lalpulsar_knope_automation_script.cronwrapper |
Definition at line 634 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.fp = open(cronwrapperscript, "w") |
Definition at line 646 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.job = cron.new(command=cronwrapperscript, comment=cronid) |
Definition at line 664 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.day = now.datetime.day |
Definition at line 667 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.month = now.datetime.month |
Definition at line 668 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.year = now.datetime.year |
Definition at line 669 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.hour = now.datetime.hour |
Definition at line 670 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.minute = now.datetime.minute |
Definition at line 671 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.dow = now.datetime.strftime("%a").upper() |
Definition at line 672 of file lalpulsar_knope_automation_script.py.
RUN ANALYSIS SCRIPT ###.
Definition at line 704 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.out |
Definition at line 705 of file lalpulsar_knope_automation_script.py.
lalpulsar_knope_automation_script.err |
Definition at line 705 of file lalpulsar_knope_automation_script.py.