diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-04 10:32:55 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-04 10:32:55 +0100 |
| commit | 75c4caa934676f4addf633008d20137b45c15c86 (patch) | |
| tree | bee177864faafb85d087a67cc92c54e9f71ff326 /test_joblib.py | |
| parent | 204bab3cd5a04a8d46d0255a02e4745d5ae8134e (diff) | |
| download | joblib-75c4caa934676f4addf633008d20137b45c15c86.tar.gz joblib-75c4caa934676f4addf633008d20137b45c15c86.zip | |
add status()
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") |
