revert

onna · Sep 17, 2024 · 450e3d3 · 450e3d3
1 parent 898911a
commit 450e3d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafkaesk/consumer.py b/kafkaesk/consumer.py
@@ -62,7 +62,7 @@ def _pydantic_msg_handler(
 ) -> pydantic.BaseModel:
     try:
         data: typing.Dict[str, typing.Any] = orjson.loads(record.value)
-        return model.model_construct(**data["data"])
+        return model.parse_obj(data["data"])
     except orjson.JSONDecodeError:
         # log the execption so we can see what fields failed
         logger.warning(f"Payload is not valid json: {record}", exc_info=True)