mirror of https://github.com/peter4431/rq.git
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
37 lines
917 B
Python
37 lines
917 B
Python
# -*- coding: utf-8 -*-
|
|
from __future__ import (absolute_import, division, print_function,
|
|
unicode_literals)
|
|
|
|
from rq import get_failed_queue, Queue, Worker
|
|
from rq.contrib.sentry import register_sentry
|
|
|
|
from tests import RQTestCase
|
|
|
|
|
|
class FakeSentry(object):
|
|
servers = []
|
|
|
|
def captureException(self, *args, **kwds):
|
|
pass # we cannot check this, because worker forks
|
|
|
|
|
|
class TestSentry(RQTestCase):
|
|
|
|
def test_work_fails(self):
|
|
"""Non importable jobs should be put on the failed queue event with sentry"""
|
|
q = Queue()
|
|
failed_q = get_failed_queue()
|
|
|
|
# Action
|
|
q.enqueue('_non.importable.job')
|
|
self.assertEquals(q.count, 1)
|
|
|
|
w = Worker([q])
|
|
register_sentry(FakeSentry(), w)
|
|
|
|
w.work(burst=True)
|
|
|
|
# Postconditions
|
|
self.assertEquals(failed_q.count, 1)
|
|
self.assertEquals(q.count, 0)
|