updateRunHistoryTables.py

Go to the documentation of this file.

import sys
import os
import psycopg2

det=sys.argv[1]
part=sys.argv[2]
minrun=sys.argv[3]

if det == 'FarDet':
    try:
        conn = psycopg2.connect("dbname=nova_prod host=novadaq-far-db-01.fnal.gov user=novadaq port=5432")
    except:
        print "I am unable to connect to the database"
        exit(0)
elif (det == 'NearDet') or (det =="TestBeam"):
    try:
        conn = psycopg2.connect("dbname=nova_prod host=novadaq-near-db-03.fnal.gov user=novadaq port=5432")
    except:
        print "I am unable to connect to the database"
        exit(0)
    
cur = conn.cursor()
    
SQL = "select run from {}.runs where run>{} and tstop is NULL and partition={} and tstart>now()-interval '7 day' order by run desc".format(det,minrun,part)

#if det == 'FarDet':
#    SQL = "select run from {}.runs where run>{} and tstop is NULL and partition={} and tstart<now()-interval '6 hour' order by run desc".format(det,minrun,part)

cur.execute(SQL)

rows = cur.fetchall()

isFirst = True

for row in rows:
    if isFirst:
        isFirst = False
        print "Skipping most recent run: ", row[0]
    else:
        run = row[0]
        cmd = "updateRunHistoryTables -d {} {}".format(det,run)
        print cmd
        os.system(cmd)