tweaks

csst_dag/dag/_base_dag.py

@@ -69,5 +69,6 @@ class BaseDAG:
         return dag_run_id
 
     @abstractmethod
-    def push(self, msg: str) -> None:
-        return self.dfs.redis.push(msg)
+    def push(self, msg_dict: dict) -> None:
+        msg_str = json.dumps(msg_dict, ensure_ascii=False, indent=None)
+        return self.dfs.redis.push(msg_str)

csst_dag/dag/msc.py

@@ -101,7 +101,4 @@ class CsstMscL1Mbi(BaseDAG):
                     )
                     assert this_update.success, this_update.message
                 msgs.append(this_msg)
-                # self.push(msg)
         return msgs
-        # push msg
-        # update prc_status