fix: fix DAQJobRemote msgspec deseralization

ENRG-tr · Nov 7, 2024 · 5ed71c8 · 5ed71c8
1 parent 363107b
commit 5ed71c8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/daq/jobs/remote.py b/src/daq/jobs/remote.py
@@ -120,7 +120,7 @@ def _unpack_message(self, message: bytes) -> DAQJobMessage:
                 raise Exception(f"Invalid message type: {message_type}")
             message_class = self._message_class_cache[message_type]
 
-            res = message_class(**data)
+            res = msgspec.convert(data, type=message_class)
 
         if res.id is None:
             raise Exception("Message id is not set")