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

Better handling of large retries

Browse Source
This commit is contained in:
tcely 2025-06-14 14:58:53 -04:00 committed by GitHub
parent 93b5ef7d43
commit 328682160e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tubesync/common/huey.py
View File

@ -74,10 +74,13 @@ def exponential_backoff(task_func=None, /, *args, **kwargs):
try: try:
return fn(*a, **kwa) return fn(*a, **kwa)
except Exception as exc: except Exception as exc:
attempt = 1 for attempt in range(1, 1_001):
while task.retry_delay <= backoff(attempt): if backoff(attempt) > task.retry_delay:
attempt += 1 task.retry_delay = backoff(attempt)
task.retry_delay = backoff(attempt) break
# insanity, but handle it anyway
if 1_000 == attempt:
task.retry_delay = backoff(attempt)
raise exc raise exc
kwargs.update(dict( kwargs.update(dict(
context=True, context=True,