GetNextRunList Namespace Reference

Functions
list[int]	get_runs_since (int run_number)
def	main ()

Variables
	SCRIPTDIR = os.path.dirname(os.path.realpath(__file__))
	DATADIR = os.environ.get('DCSC_DATADIR', SCRIPTDIR)

Function Documentation

get_runs_since()

list[int] GetNextRunList.get_runs_since

(

int

run_number

)

Get runs that occured since `run_number`, excluding it.

Definition at line 11 of file GetNextRunList.py.

def get_runs_since(run_number: int) -> list[int]:
    """
    Get runs that occured since `run_number`, excluding it.
    """
    s = ServerProxy('http://atlasdqm.cern.ch:8080')
    run_list: list[int] = s.get_completed_runs({'low_run': run_number})  # type: ignore
    if run_number in run_list:
        run_list.remove(run_number)
    return run_list
 

main()

def GetNextRunList.main

(

)

Read the lastRunNumber file, find runs which happened since it.
Then create a runList file containing these runs, and overwrite lastRunNumber.

Definition at line 21 of file GetNextRunList.py.

def main():
    """
    Read the lastRunNumber file, find runs which happened since it.
    Then create a runList file containing these runs, and overwrite lastRunNumber.
    """
    try:
        last_run = int(open(os.path.join(DATADIR, "lastRunNumber"), 'r+').read())
    except Exception:
        last_run = 450000
    new_runs = get_runs_since(last_run)
    
    open(os.path.join(DATADIR, "runList"), "w").write("\n".join(map(str, new_runs)))
    
    if not new_runs:
        print(strftime("%d/%m/%Y %H:%M:%S"), "Nothing to do")
        return
    
    last_run = new_runs[-1]
    open(os.path.join(DATADIR, "lastRunNumber"), "w").write(str(last_run)+"\n")
    print(strftime("%d/%m/%Y %H:%M:%S"), "Wrote new runList. Last run is", last_run, new_runs)
 

Variable Documentation

DATADIR

GetNextRunList.DATADIR = os.environ.get('DCSC_DATADIR', SCRIPTDIR)

Definition at line 5 of file GetNextRunList.py.

SCRIPTDIR

GetNextRunList.SCRIPTDIR = os.path.dirname(os.path.realpath(__file__))

Definition at line 4 of file GetNextRunList.py.