Skip to content
Snippets Groups Projects
sqlite_view.py 899 B
import argparse
import sqlite3

parser = argparse.ArgumentParser(
    description='Update run status at MDC for a given run id.')
parser.add_argument('--sqlite-fpath', type=str, help='Path to sqlite file path',
                    default='/home/xcal/calibration_webservice/webservice/webservice_jobs.sqlite')  # noqa
parser.add_argument('--run', type=str, help='The run number required '
                                            ' for checking its job status.')
parser.add_argument('--proposal', type=str, help='Proposal numer')

args = vars(parser.parse_args())

sqlite_fpath = args['sqlite_fpath']
proposal = args['proposal'].zfill(6)
run = args['run']

conn = sqlite3.connect(sqlite_fpath)
c = conn.cursor()

c.execute("SELECT * FROM jobs")

for r in c.fetchall():
    rid, jobid, db_proposal, db_run, status, time, _, _ = r
    if db_proposal == proposal and db_run == run:
        print(r)