Skip to content

Commit be8a4c6

Browse files
committed
fix(worker): test_job_timeout
1 parent 5085659 commit be8a4c6

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

tests/test_worker.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -980,10 +980,11 @@ async def longfunc(ctx):
980980
assert worker.jobs_complete == 0
981981
assert worker.jobs_failed == 0
982982
assert worker.jobs_retried == 0
983+
assert worker.retry_jobs
983984
await worker.main()
984985
assert worker.jobs_complete == 0
985986
assert worker.jobs_failed == 1
986-
assert worker.jobs_retried == 0
987+
assert worker.jobs_retried == worker.max_tries
987988
log = re.sub(r'\d+.\d\ds', 'X.XXs', '\n'.join(r.message for r in caplog.records))
988989
assert 'X.XXs ! testing:longfunc failed, TimeoutError:' in log
989990

0 commit comments

Comments
 (0)