Tests passing

ask · ask · commit 603d0b74874c · 2012-08-05T15:51:58.000+01:00
diff --git a/celery/tests/concurrency/test_processes.py b/celery/tests/concurrency/test_processes.py
@@ -161,14 +161,10 @@ def test_apply_async(self):
         pool.apply_async(lambda x: x, (2, ), {})
 
     def test_terminate_job(self):
-
-        @patch('celery.concurrency.processes._kill')
-        def _do_test(_kill):
-            pool = TaskPool(10)
-            pool.terminate_job(1341)
-            _kill.assert_called_with(1341, signal.SIGTERM)
-
-        _do_test()
+        pool = TaskPool(10)
+        pool._pool = Mock()
+        pool.terminate_job(1341)
+        pool._pool.terminate_job.assert_called_with(1341, None)
 
     def test_grow_shrink(self):
         pool = TaskPool(10)
