From 75c4caa934676f4addf633008d20137b45c15c86 Mon Sep 17 00:00:00 2001 From: schneefux Date: Sat, 4 Mar 2017 10:32:55 +0100 Subject: add status() --- test_joblib.py | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'test_joblib.py') diff --git a/test_joblib.py b/test_joblib.py index f9aa875..865cfab 100644 --- a/test_joblib.py +++ b/test_joblib.py @@ -77,6 +77,17 @@ class TestJoblib: payload["error"] = err 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) -- cgit v1.3.1