Skip to content

Commit c76a853

Browse files
committed
fix: using pool_size as pg conn min_size if not set
1 parent 310100a commit c76a853

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/pgmq/queue.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ def __post_init__(self) -> None:
3737
user={self.username}
3838
password={self.password}
3939
"""
40+
self.kwargs.setdefault("min_size", self.pool_size)
4041
self.pool = ConnectionPool(conninfo, open=True, **self.kwargs)
4142
self._initialize_logging()
4243
if self.init_extension:

0 commit comments

Comments
 (0)