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

_copy_sync refactor

Browse Source
This commit is contained in:
AF 2022-11-04 06:45:53 +00:00
parent 1bba6902d0
commit 243741346e
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
ptvp35/__init__.py
View File

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