summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--joblib.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/joblib.py b/joblib.py
index 0e0cc41..53a34c1 100644
--- a/joblib.py
+++ b/joblib.py
@@ -15,7 +15,8 @@ class JobQueue(object):
logging.info("connecting to queue database")
while True:
try:
- self._pool = await asyncpg.create_pool(**args)
+ self._pool = await asyncpg.create_pool(
+ min_size=1, **args)
break
except asyncpg.exceptions.CannotConnectNowError:
logging.warning(