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-03.fnal.gov user=novadaq port=5432")
    except:
        print "I am unable to connect to the database"
        exit(0)
elif det == 'NearDet':
    try:
        conn = psycopg2.connect("dbname=nova_prod host=novadaq-near-db-01.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<'yesterday' order by run desc".format(det,minrun,part)

cur.execute(SQL)

rows = cur.fetchall()

for row in rows:
    run = row[0]
    cmd = "updateRunHistoryTables -d {} {}".format(det,run)
#        cmd = "updateRunHistoryTables {} {}".format(det,run)
    print cmd
    os.system(cmd)