diff --git a/src/daq/jobs/remote.py b/src/daq/jobs/remote.py
index 0799b24..2524bd2 100644
--- 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")