File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -24,13 +24,17 @@ async def main():
2424 logger .terror ("orm.error.failed" , e = e )
2525
2626 async def syncFiles ():
27+ if cluster .enabled :
28+ await cluster .disable ()
2729 await cluster .fetchFileList ()
2830 missing_filelist = await cluster .getMissingFiles ()
2931 await cluster .syncFiles (
3032 missing_filelist ,
3133 Config .get ("advanced.retry" ),
3234 Config .get ("advanced.delay" ),
3335 )
36+ if not cluster .enabled :
37+ await cluster .enable ()
3438
3539 await syncFiles ()
3640 scheduler .add_job (
@@ -47,8 +51,9 @@ async def syncFiles():
4751 await cluster .enable ()
4852 if not cluster .enabled :
4953 raise asyncio .CancelledError
50- await cluster .keepAlive ()
5154 scheduler .start ()
55+ asyncio .sleep (10 )
56+ await cluster .keepAlive ()
5257 logger .tsuccess ("main.success.scheduler" )
5358 while True :
5459 await asyncio .sleep (3600 )
You can’t perform that action at this time.
0 commit comments