diff options
Diffstat (limited to 'test_joblib.py')
| -rw-r--r-- | test_joblib.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/test_joblib.py b/test_joblib.py index f9aa875..865cfab 100644 --- a/test_joblib.py +++ b/test_joblib.py @@ -78,6 +78,17 @@ class TestJoblib: assert json.loads(pl) == payload @pytest.mark.asyncio + async def test_status(self, queue, payload): + assert await queue.status(-1) == None + jobid = await queue.request(jobtype="testing", + payload=payload) + assert await queue.status(jobid) == "open" + await queue.acquire(jobtype="testing") + assert await queue.status(jobid) == "running" + await queue.finish(jobid) + assert await queue.status(jobid) == "finished" + + @pytest.mark.asyncio async def test_finish(self, queue, payload): await queue.request(jobtype="testing", payload=payload) jobid, _, _ = await queue.acquire(jobtype="testing") |