Catch unpickling error

This commit is contained in:
Nicolas Mowen 2025-06-20 06:44:48 -06:00
parent b142a69c89
commit 54bee5ed85

View File

@ -1,6 +1,7 @@
"""Facilitates communication between processes."""
import multiprocessing as mp
from _pickle import UnpicklingError
from multiprocessing.synchronize import Event as MpEvent
from typing import Any, Optional
@ -50,7 +51,7 @@ class ConfigSubscriber:
return (topic, obj)
else:
return (None, None)
except (zmq.ZMQError, UnicodeDecodeError):
except (zmq.ZMQError, UnicodeDecodeError, UnpicklingError):
return (None, None)
def stop(self) -> None: