PTV/ptvp35
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases 4 Wiki Activity

refactor copy

Browse Source
This commit is contained in:
AF 2022-11-04 06:40:25 +00:00
parent da8db42dae
commit 1bba6902d0
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ptvp35/__init__.py
View File

@ -225,9 +225,12 @@ class DbConnection:
while True:
await self._background_cycle()
async def _finish_recovery(self):
async def _copy(self):
with concurrent.futures.ThreadPoolExecutor() as pool:
await self.__loop.run_in_executor(pool, shutil.copy, self.__path_backup, self.__path)
await self.__loop.run_in_executor(pool, shutil.copyfile, self.__path_backup, self.__path)
async def _finish_recovery(self):
await self._copy()
self.__path_recover.unlink()
self.__path_backup.unlink()