app_id=50
job_name="message-router-csst"
dag_run_id="ecdec5a84a56e2f0bae042a71b21af2c8512ae6c"
priority=1
message='{"dag_group":"csst-cpic-l1-test","dag_group_run":"588f023b09c631d607c4c63494abc7c91a18a3fe","batch_id":"csci-cpic-251210","dag":"csst-cpic-l1","dag_run":"ecdec5a84a56e2f0bae042a71b21af2c8512ae6c","dataset":"csst-cpic-c11-csci-ptc-v1","instrument":"CPIC","obs_type":"SCI","obs_group":"csci-ptc-v1","obs_id":"40100000002","detector":"VIS","filter":"","object":"","proposal_id":"","custom_id":"","priority":1,"data_list":["6938df5eb5b42a5a15e90673"],"extra_kwargs":{},"rerun":-1,"status_code":-1024,"queue_time":"2025-12-16T17:54:03.235735","pmapname":"","ref_cat":"","created_time":"2025-12-16T09:54:03.150","n_file_expected":1,"n_file_found":1}'
strdatalist='[6938df5eb5b42a5a15e90673]'
scalebox task add --app-id ${app_id} \
                --header sorted_tag=${priority} \
                --header dag_run_id=${dag_run_id} \
                --header repeatable=yes \
                --header data_list=${strdatalist} \
                --upsert --sink-job ${job_name} ${message}