bidirectional wrapper

This commit is contained in:
dltn 2024-10-09 11:28:11 -07:00
parent 3adf1dc20e
commit fd41ddf733

View file

@ -124,7 +124,7 @@ def mp_rank_0() -> bool:
def encode_msg(msg: ProcessingMessage) -> bytes: def encode_msg(msg: ProcessingMessage) -> bytes:
return msg.model_dump_json().encode("utf-8") return ProcessingMessageWrapper(payload=msg).model_dump_json().encode("utf-8")
def retrieve_requests(reply_socket_url: str): def retrieve_requests(reply_socket_url: str):