Loading src/common/message_broker/backend/nats/NatsBackendThread.py +1 −1 Original line number Diff line number Diff line Loading @@ -70,7 +70,7 @@ class NatsBackendThread(threading.Thread): out_queue.put(Message(message.subject, message.data.decode('UTF-8'))) await subscription.unsubscribe() await client.drain() except Exception as e: except Exception: # pylint: disable=broad-exception-caught LOGGER.exception('[_run_subscriber] Unhandled Exception') def subscribe( Loading Loading
src/common/message_broker/backend/nats/NatsBackendThread.py +1 −1 Original line number Diff line number Diff line Loading @@ -70,7 +70,7 @@ class NatsBackendThread(threading.Thread): out_queue.put(Message(message.subject, message.data.decode('UTF-8'))) await subscription.unsubscribe() await client.drain() except Exception as e: except Exception: # pylint: disable=broad-exception-caught LOGGER.exception('[_run_subscriber] Unhandled Exception') def subscribe( Loading