hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-24 14:06:36 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Abort wait_for_errors during container shutdown

Browse Source
This commit is contained in:
tcely 2025-06-16 22:19:42 -04:00 committed by GitHub
parent 0486329a8b
commit 983679964b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tubesync/sync/tasks.py
View File

@ -270,9 +270,19 @@ def wait_for_errors(model, /, *, queue_name=None, task_name=None):
delay = 10 * total_count delay = 10 * total_count
time_str = seconds_to_timestr(delay) time_str = seconds_to_timestr(delay)
log.info(f'waiting for errors: 429 ({time_str}): {model}') log.info(f'waiting for errors: 429 ({time_str}): {model}')
time.sleep(delay) db_down_path = Path('/run/service/tubesync-db-worker/down')
fs_down_path = Path('/run/service/tubesync-fs-worker/down')
while delay > 0:
# this happenes when the container is shutting down
# do not prevent that while we are delaying a task
if db_down_path.exists() and fs_down_path.exists():
break
time.sleep(5)
delay -= 5
for task in tasks: for task in tasks:
update_task_status(task, None) update_task_status(task, None)
if delay > 0:
raise BgTaskWorkerError(_('queue worker stopped'))
@db_task(queue=Val(TaskQueue.FS)) @db_task(queue=Val(TaskQueue.FS))