Explorar el Código

Accidentally checked in the wrong version of a test

Ask Solem hace 15 años
padre
commit
f337aa1006
Se han modificado 1 ficheros con 3 adiciones y 0 borrados
  1. 3 0
      celery/tests/test_worker_job.py

+ 3 - 0
celery/tests/test_worker_job.py

@@ -175,7 +175,10 @@ class test_TaskRequest(unittest.TestCase):
 
     def test_execute_acks_late(self):
         mytask_raising.acks_late = True
+        tw = TaskRequest(mytask_raising.name, gen_unique_id(), [1], {"f": "x"})
         try:
+            tw.execute()
+            self.assertTrue(tw.acknowledged)
         finally:
             mytask_raising.acks_late = False