Add catchall OSError to recoverable exceptions

galaxyproject · Sep 14, 2023 · 78fa1aa · 78fa1aa
1 parent 9b86949
commit 78fa1aa
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar/client/amqp_exchange.py b/pulsar/client/amqp_exchange.py
@@ -86,6 +86,7 @@ def __init__(
             ConnectionResetError,  # https://github.com/galaxyproject/pulsar/issues/328
             TimeoutError,
             socket.timeout,
+            OSError,  # Needed as long as py-ampq raises plain OSError: https://github.com/celery/py-amqp/blob/a92dd037712b5b7b1622f4f9d83157d095c90910/amqp/transport.py#L584
             amqp.exceptions.ConnectionForced,  # e.g. connection closed on rabbitmq sigterm
             amqp.exceptions.RecoverableConnectionError,  # connection closed
             amqp.exceptions.RecoverableChannelError,  # publish time out