refactor: swap assert with raise in DAQJobRemote

ENRG-tr · Oct 19, 2024 · cfede93 · cfede93
1 parent a6c5dad
commit cfede93
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/daq/jobs/remote.py b/src/daq/jobs/remote.py
@@ -95,7 +95,9 @@ def _unpack_message(self, message: bytes) -> DAQJobMessage:
         message_class = self._message_class_cache[message_type]
 
         res = message_class.from_json(data)
-        assert res.id is not None, "Message id is not set"
+        if res.id is None:
+            raise Exception("Message id is not set")
+
         self._remote_message_ids.add(res.id)
         if len(self._remote_message_ids) > DAQ_JOB_REMOTE_MAX_REMOTE_MESSAGE_ID_COUNT:
             self._remote_message_ids.pop()