Loading csst_dag/dag/msc.py +7 −6 Original line number Diff line number Diff line Loading @@ -86,19 +86,20 @@ class CsstMscL1Mbi(BaseDAG): project_id=project_id, batch_id=batch_id, obs_id=this_rec["obs_id"], chipid=this_rec["detector_no"], chip_id=this_rec["detector_no"], dag_run_id=self.gen_dag_run_id(), **kwargs, ) if not demo: level0.update_prc_status( this_rec["level0_id"], this_msg["dag_run_id"], # push and update self.push(this_msg) this_update = level0.update_prc_status( level0_id=this_rec["level0_id"], dag_run_id=this_msg["dag_run_id"], prc_status=-2, dataset=dataset, ) self.push(this_msg) assert this_update.success, this_update.message msgs.append(this_msg) # self.push(msg) return msgs Loading Loading
csst_dag/dag/msc.py +7 −6 Original line number Diff line number Diff line Loading @@ -86,19 +86,20 @@ class CsstMscL1Mbi(BaseDAG): project_id=project_id, batch_id=batch_id, obs_id=this_rec["obs_id"], chipid=this_rec["detector_no"], chip_id=this_rec["detector_no"], dag_run_id=self.gen_dag_run_id(), **kwargs, ) if not demo: level0.update_prc_status( this_rec["level0_id"], this_msg["dag_run_id"], # push and update self.push(this_msg) this_update = level0.update_prc_status( level0_id=this_rec["level0_id"], dag_run_id=this_msg["dag_run_id"], prc_status=-2, dataset=dataset, ) self.push(this_msg) assert this_update.success, this_update.message msgs.append(this_msg) # self.push(msg) return msgs Loading