From 46512ef68d91280c8f14d95cc44613b5e5235704 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Sat, 29 Jun 2019 12:05:10 -0700
Subject: release lock on Exception in oauth

---
 kafka/conn.py | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'kafka')

diff --git a/kafka/conn.py b/kafka/conn.py
index 37df802..c5b51f1 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -704,6 +704,9 @@ class BrokerConnection(object):
             error = Errors.KafkaConnectionError("%s: %s" % (self, e))
             self.close(error=error)
             return future.failure(error)
+        except Exception:
+            self._lock.release()
+            raise
 
         self._lock.release()
 
-- 
cgit v1.2.1