cubicweb/server/repository.py
changeset 12805 8cf02773a6b3
parent 12804 6de3af773073
child 12806 91e262556573
--- a/cubicweb/server/repository.py	Thu Dec 05 18:36:55 2019 +0100
+++ b/cubicweb/server/repository.py	Thu Dec 05 18:37:27 2019 +0100
@@ -147,12 +147,15 @@
 
     def __init__(self, source, size):
         self._cnxsets = []
+
         if size is not None:
             self._queue = queue.Queue()
+
             for i in range(size):
                 cnxset = source.wrapped_connection()
                 self._cnxsets.append(cnxset)
                 self._queue.put_nowait(cnxset)
+
         else:
             self._queue = None
             self._source = source
@@ -160,11 +163,13 @@
     def qsize(self):
         if self._queue is None:
             return None
+
         return self._queue.qsize()
 
     def get(self):
         if self._queue is None:
             return self._source.wrapped_connection()
+
         try:
             return self._queue.get(True, timeout=5)
         except queue.Empty:
@@ -188,6 +193,7 @@
         if self._queue is not None:
             while not self._queue.empty():
                 cnxset = self._queue.get_nowait()
+
                 try:
                     cnxset.close(True)
                 except Exception: