voussoir/ycdl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Move refresher thread launcher into a function.

Browse source
This commit is contained in:
voussoir 2020-03-28 16:42:54 -07:00
parent d0bfbaadfe
commit 9fe7057021
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
frontends/ycdl_flask/ycdl_flask/ycdl_flask.py
View file

@ -271,16 +271,18 @@ def post_start_download():
#################################################################################################### ####################################################################################################
#################################################################################################### ####################################################################################################
def refresher_thread(): def refresher_thread(rate):
while True: while True:
time.sleep(60 * 60 * 6) time.sleep(rate)
print('Starting refresh job.') print('Starting refresh job.')
thread_kwargs = {'force': False, 'skip_failures': True} thread_kwargs = {'force': False, 'skip_failures': True}
refresh_job = threading.Thread(target=ycdldb.refresh_all_channels, kwargs=thread_kwargs, daemon=True) refresh_job = threading.Thread(target=ycdldb.refresh_all_channels, kwargs=thread_kwargs, daemon=True)
refresh_job.start() refresh_job.start()
refresher = threading.Thread(target=refresher_thread, daemon=True) def start_refresher_thread(rate):
refresher.start() print(f'Starting refresher thread, once per {rate} seconds.')
refresher = threading.Thread(target=refresher_thread, args=[rate], daemon=True)
refresher.start()
if __name__ == '__main__': if __name__ == '__main__':
pass pass