trigger.py

"""
COSMOS
"""

# cd /nfsdata/share/simulation-collection/csst-dag
# http://159.226.170.52:3000/scalebox/TaskList?app=csst-msc-l1-mbi.apps2

from csst_dag import get_redis, gen_level1_dag_message
from csst_dag.msc import MBI_CHIPID, SLS_CHIPID
import numpy as np

r = get_redis(location="naoc")
obsid_list = np.loadtxt("batch/msc_096/obsid.txt", dtype=str)
for obsid in obsid_list:
    for chipid in MBI_CHIPID:
        msg = gen_level1_dag_message(obsid=obsid, chipid=chipid)
        print(msg)
        r.push(msg)
    break

r.get_all()