From 119362ab2b0c3f00bb80b927641f478a847ac1d9 Mon Sep 17 00:00:00 2001 From: schneefux Date: Sun, 26 Feb 2017 18:31:14 +0100 Subject: add job fails --- test_joblib.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) (limited to 'test_joblib.py') diff --git a/test_joblib.py b/test_joblib.py index 47eedec..f9aa875 100644 --- a/test_joblib.py +++ b/test_joblib.py @@ -2,6 +2,7 @@ import os import asyncio +import json import asyncpg import pytest import joblib @@ -63,6 +64,19 @@ class TestJoblib: await queue.request(jobtype="testing", payload=payload, priority=9) assert 9 == (await queue.acquire(jobtype="testing"))[2] + @pytest.mark.asyncio + async def test_fail(self, queue, payload): + err = "testing errors" + await queue.request(jobtype="testing", payload=payload) + jobid, _, _ = await queue.acquire(jobtype="testing") + await queue.fail(jobid, err) + async with queue._pool.acquire() as con: + jid, pl = await con.fetchrow( + "SELECT id, payload FROM jobs WHERE status='failed'") + assert jid == jobid + payload["error"] = err + assert json.loads(pl) == payload + @pytest.mark.asyncio async def test_finish(self, queue, payload): await queue.request(jobtype="testing", payload=payload) -- cgit v1.3.1