Skip to content

Commit b504b46

Browse files
committed
Fix _send_channel_lock not excluded from pickle — rabbitmq_channel.py:122
asyncio.Lock is not safely picklable. Added "_send_channel_lock" to the exclusion list in __getstate__.
1 parent 796c82e commit b504b46

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

plugboard/connector/rabbitmq_channel.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ def __init__(self, *args: _t.Any, **kwargs: _t.Any) -> None:
120120

121121
def __getstate__(self) -> dict:
122122
state = self.__dict__.copy()
123-
for attr in ("_send_channel", "_recv_channel", "_recv_channel_lock"):
123+
for attr in ("_send_channel", "_send_channel_lock", "_recv_channel", "_recv_channel_lock"):
124124
if attr in state:
125125
del state[attr]
126126
return state

0 commit comments

Comments
 (0)