This commit is contained in:
Alexey Polyakov
2026-05-06 15:39:22 +03:00
parent 389a08ebce
commit 49d73200b0

View File

@@ -197,7 +197,14 @@ async def main():
await asyncio.gather(*running_tasks) await asyncio.gather(*running_tasks)
except (asyncio.CancelledError, Exception): except (asyncio.CancelledError, Exception):
logging.info("Все задачи завершены, выходим") logging.info("Все задачи завершены, выходим")
finally:
if hasattr(db, 'close'):
db.close()
await db.wait_closed()
elif hasattr(db, 'connection') and hasattr(db.connection, 'close'):
await db.connection.close()
if __name__ == "__main__": if __name__ == "__main__":
asyncio.run(main()) asyncio.run(main())