Skip to content

Commit e1da6c6

Browse files
committed
adding disconnect function
1 parent 2e93216 commit e1da6c6

File tree

3 files changed

+19
-3
lines changed

3 files changed

+19
-3
lines changed

coverage-badge.svg

Lines changed: 1 addition & 1 deletion
Loading

coverage.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
<?xml version="1.0" ?>
2-
<coverage version="7.6.0" timestamp="1722642128956" lines-valid="716" lines-covered="193" line-rate="0.2696" branches-covered="0" branches-valid="0" branch-rate="0" complexity="0">
3-
<!-- Generated by coverage.py: https://coverage.readthedocs.io/en/7.6.0 -->
2+
<coverage version="7.6.1" timestamp="1724623192815" lines-valid="716" lines-covered="193" line-rate="0.2696" branches-covered="0" branches-valid="0" branch-rate="0" complexity="0">
3+
<!-- Generated by coverage.py: https://coverage.readthedocs.io/en/7.6.1 -->
44
<!-- Based on https://raw.githubusercontent.com/cobertura/web/master/htdocs/xml/coverage-04.dtd -->
55
<sources>
66
<source>/workspaces/devsetgo_lib</source>

dsg_lib/async_database_functions/async_database.py

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -120,3 +120,19 @@ async def create_tables(self):
120120
# Log the error and raise it
121121
logger.error(f"Error creating tables: {ex}") # pragma: no cover
122122
raise # pragma: no cover
123+
124+
async def disconnect(self): # pragma: no cover
125+
"""
126+
This method asynchronously disconnects the database engine.
127+
128+
Parameters: None
129+
130+
Returns: None
131+
"""
132+
logger.debug("Disconnecting from database")
133+
try:
134+
await self.db_config.engine.dispose()
135+
logger.info("Disconnected from database")
136+
except Exception as ex: # pragma: no cover
137+
logger.error(f"Error disconnecting from database: {ex}") # pragma: no cover
138+
raise # pragma: no cover

0 commit comments

Comments
 (0)