Skip to content

Commit 297f6d8

Browse files
removes connection closing mechanism
1 parent a7afebd commit 297f6d8

File tree

2 files changed

+0
-7
lines changed

2 files changed

+0
-7
lines changed

lib/repositories/environment.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,6 @@ async def create_env(self):
6262
logger.info(
6363
f"Call to repositories.environment.create_env completed; states: EnvID {self.env_id}"
6464
)
65-
await self.close_connection()
6665

6766
async def update_env(self):
6867
"""
@@ -88,7 +87,6 @@ async def update_env(self):
8887
logger.info(
8988
f"Call to repositories.environment.update_env completed; states: Env {hash(self.env)}, EnvID {self.env_id}"
9089
)
91-
await self.close_connection()
9290

9391
async def get_env(self) -> "Union[Env, None]":
9492
"""
@@ -108,7 +106,6 @@ async def get_env(self) -> "Union[Env, None]":
108106
logger.info(
109107
f"Call to repositories.environment.get_env completed; states: Env {hash(self.env)}, EnvID {self.env_id}"
110108
)
111-
await self.close_connection()
112109

113110
async def delete_env(self):
114111
"""
@@ -126,4 +123,3 @@ async def delete_env(self):
126123
logger.info(
127124
f"Call to repositories.environment.delete_env completed; states: Env {hash(self.env)}, EnvID {self.env_id}"
128125
)
129-
await self.close_connection()

lib/repositories/repo.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,3 @@ def __init__(self, collection: str):
2424
)
2525
self.db = self.client.rocketpy
2626
self.collection = self.db[collection]
27-
28-
async def close_connection(self) -> None:
29-
self.client.close()

0 commit comments

Comments
 (0)