run_catalog.py

#!/usr/bin/python3

import os.path
import sys
sys.path.append('/home/ubuntu/proj/websrv/temp-clone')
import numpy as np
from astropy.time import Time
from astropy.coordinates import EarthLocation
from astropy import units as u
from dsautils import dsa_store
import sched_funcs

d = dsa_store.DsaStore()

test = False  # remove for live system or add parameter to webUI

d.put_dict('/cnf/datestring', sched_funcs.get_datestring())

# update trig_ct
if not test:
    for i in np.arange(1,21):
        d.put_dict('/mon/corr/'+str(i)+'/voltage_ct',{'n_trigs':0})

# get catalog
catalogname = 'catalog.yaml'
if os.path.exists(catalogname):
    catalog = catalogname
else:
    catalog = os.path.join('/home/ubuntu/proj/websrv/temp-clone/', catalogname)
srcs = sched_funcs.read_srcs(catalog)
ovro = EarthLocation(lon=-118.2951 * u.deg, lat=37.2317 * u.deg, height=1222 * u.m)
start_time = Time.now()   # or fixed offset from now?

# calculate actions
srcs2, transit_times, max_alts, stimes, end_times, northy = sched_funcs.return_times_day(srcs, start_time, ovro)
schedule = sched_funcs.define_actions_simple(srcs2, transit_times, max_alts, stimes, end_times, northy, recording=True)

# TODO: save schedule as actions.npy?

# run schedule
for ln in schedule:
    print(ln)
    if not test:
        sched_funcs.pause_until(ln['time'])
        sched_funcs.exec_action(ln, d)