Bail out early from NextId.__current_id getter

pottery/nextid.py

@@ -133,7 +133,9 @@ def __repr__(self) -> str:
 
     @property
     def __current_id(self) -> int:
-        with concurrent.futures.ThreadPoolExecutor() as executor:
+        quorum = False
+
+        with BailOutExecutor() as executor:
             futures = set()
             for master in self.masters:
                 futures.add(executor.submit(master.get, self.key))
@@ -144,12 +146,16 @@ def __current_id(self) -> int:
                     current_ids.append(int(future.result()))
                 except RedisError as error:
                     _logger.error(error, exc_info=True)
+                else:
+                    num_masters_gotten = len(current_ids)
+                    quorum = num_masters_gotten >= len(self.masters) // 2 + 1
+                    if quorum:  # pragma: no cover
+                        break
 
-        num_masters_gotten = len(current_ids)
-        if num_masters_gotten < len(self.masters) // 2 + 1:
-            raise QuorumNotAchieved(self.masters, self.key)
-        else:
+        if quorum:
             return max(current_ids)
+        else:
+            raise QuorumNotAchieved(self.masters, self.key)
 
     @__current_id.setter
     def __current_id(self, value: int) -> None: