Skip to content

Commit c4e89b3

Browse files
committed
fix for python 3.6
1 parent b645cce commit c4e89b3

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

tests/test_worker.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -203,7 +203,10 @@ async def test_job_expired_run_check(arq_redis: ArqRedis, worker, caplog):
203203
with pytest.raises(FailedJobs) as exc_info:
204204
await worker.run_check()
205205

206-
assert str(exc_info.value) == "1 job failed JobExecutionFailed('job expired')"
206+
assert str(exc_info.value) in {
207+
"1 job failed JobExecutionFailed('job expired',)", # python 3.6
208+
"1 job failed JobExecutionFailed('job expired')", # python 3.7
209+
}
207210
assert exc_info.value.count == 1
208211
assert len(exc_info.value.job_results) == 1
209212
assert exc_info.value.job_results[0].result == JobExecutionFailed('job expired')
@@ -348,7 +351,7 @@ async def test_run_check_passes(arq_redis: ArqRedis, worker):
348351
async def test_run_check_error(arq_redis: ArqRedis, worker):
349352
await arq_redis.enqueue_job('fails')
350353
worker: Worker = worker(functions=[func(fails, name='fails')])
351-
with pytest.raises(FailedJobs, match=r"1 job failed TypeError\('my type error'\)"):
354+
with pytest.raises(FailedJobs, match=r"1 job failed TypeError\('my type error'"):
352355
await worker.run_check()
353356

354357

0 commit comments

Comments
 (0)