added missing tests and updated version information

Author: Matt George

HISTORY.md

@@ -1,3 +1,7 @@
+## 0.4.0 (2010-01-06)
+
+* added the basics of failure backend support
+
 ## 0.3.1 (2009-12-16)
 
 * minor bug fix in worker.py

pyres/__init__.py

@@ -1,4 +1,4 @@
-__version__ = '0.3.1'
+__version__ = '0.4.0'
 
 from redis import Redis
 import simplejson

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name='PyRes',
-    version='0.3.1',
+    version='0.4.0',
     description='Python Resque clone',
     author='Matt George',
     license='MIT',

tests/test_failure.py

@@ -0,0 +1,48 @@
+from tests import PyResTests, Basic, TestProcess, ErrorObject
+from pyres import failure
+from pyres.job import Job
+class FailureTests(PyResTests):
+    def test_count(self):
+        self.resq.enqueue(Basic,"test1")
+        job = Job.reserve('basic',self.resq)
+        job.fail("problem")
+        assert failure.count(self.resq) == 1
+        assert self.redis.llen('resque:failed') == 1
+    
+    def test_create(self):
+        self.resq.enqueue(Basic,"test1")
+        job = Job.reserve('basic',self.resq)
+        e = Exception('test')
+        fail = failure.create(e, 'basic', job._payload)
+        assert isinstance(fail._payload, dict)
+        fail.save()
+        assert failure.count(self.resq) == 1
+        assert self.redis.llen('resque:failed') == 1
+    
+    def test_all(self):
+        self.resq.enqueue(Basic,"test1")
+        job = Job.reserve('basic',self.resq)
+        e = Exception('problem')
+        job.fail(e)
+        assert len(failure.all(self.resq, 0, 20)) == 1
+    
+    def test_clear(self):
+        self.resq.enqueue(Basic,"test1")
+        job = Job.reserve('basic',self.resq)
+        e = Exception('problem')
+        job.fail(e)
+        assert self.redis.llen('resque:failed') == 1
+        failure.clear(self.resq)
+        assert self.redis.llen('resque:failed') == 0
+    
+    def test_requeue(self):
+        self.resq.enqueue(Basic,"test1")
+        job = Job.reserve('basic',self.resq)
+        e = Exception('problem')
+        fail_object = job.fail(e)
+        assert self.resq.size('basic') == 0
+        failure.requeue(self.resq, fail_object)
+        assert self.resq.size('basic') == 1
+        job = Job.reserve('basic',self.resq)
+        assert job._queue == 'basic'
+        assert job._payload == {'class':'tests.Basic','args':['test1']}