Skip to content

Commit 8f460ff

Browse files
committed
fix: extra dependencies
1 parent 6cd9210 commit 8f460ff

File tree

4 files changed

+5
-4
lines changed

4 files changed

+5
-4
lines changed

pyproject.toml

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ dependencies = [
3939
"Bug Tracker" = "https://github.com/danfimov/taskiq-postgres/issues"
4040
"Repository" = "https://github.com/danfimov/taskiq-postgres/"
4141

42-
[dependency-groups]
42+
[project.optional-dependencies]
4343
aiopg = [
4444
"aiopg>=1.4.0",
4545
]
@@ -49,6 +49,7 @@ asyncpg = [
4949
psqlpy = [
5050
"psqlpy>=0.10.1",
5151
]
52+
[dependency-groups]
5253
dev = [
5354
"ruff>=0.11.9",
5455
"pytest>=8.3.5",

src/taskiq_pg/aiopg/result_backend.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ async def startup(self) -> None:
7676

7777
async def shutdown(self) -> None:
7878
"""Close the connection pool."""
79-
if getattr(self, '_database_pool', None) is not None:
79+
if getattr(self, "_database_pool", None) is not None:
8080
self._database_pool.close()
8181

8282
async def set_result(

src/taskiq_pg/asyncpg/result_backend.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ async def startup(self) -> None:
9696

9797
async def shutdown(self) -> None:
9898
"""Close the connection pool."""
99-
if getattr(self, '_database_pool', None) is not None:
99+
if getattr(self, "_database_pool", None) is not None:
100100
await self._database_pool.close()
101101

102102
async def set_result(

src/taskiq_pg/psqlpy/result_backend.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -84,7 +84,7 @@ async def startup(self) -> None:
8484

8585
async def shutdown(self) -> None:
8686
"""Close the connection pool."""
87-
if getattr(self, '_database_pool', None) is not None:
87+
if getattr(self, "_database_pool", None) is not None:
8888
self._database_pool.close()
8989

9090
async def set_result(

0 commit comments

Comments
 (0)