Explorar o código

process cleanup should be safe to invoke after connect fails

Piotr Maślanka %!s(int64=9) %!d(string=hai) anos
pai
achega
38790108a4
Modificáronse 1 ficheiros con 3 adicións e 0 borrados
  1. 3 0
      celery/tests/backends/test_new_cassandra.py

+ 3 - 0
celery/tests/backends/test_new_cassandra.py

@@ -130,3 +130,6 @@ class test_CassandraBackend(AppCase):
             self.assertRaises(OTOExc, lambda: x._store_result('task_id', 'result', states.SUCCESS))
             self.assertIsNone(x._connection)
             self.assertIsNone(x._session)
+
+            x.process_cleanup() # assert it doesn't raise
+