[Erp5-report] r28705 - /erp5/trunk/products/CMFActivity/tests/testCMFActivity.py

[nobody at svn.erp5.org]

Author: yusei
Date: Tue Sep  1 05:46:12 2009
New Revision: 28705

URL: http://svn.erp5.org?rev=28705&view=rev
Log:
Fix test_115_TestSerializationTagSQLDictPreventsParallelExecution. Delete remaining activities at the end. This broke other test.

Modified:
    erp5/trunk/products/CMFActivity/tests/testCMFActivity.py

Modified: erp5/trunk/products/CMFActivity/tests/testCMFActivity.py
URL: http://svn.erp5.org/erp5/trunk/products/CMFActivity/tests/testCMFActivity.py?rev=28705&r1=28704&r2=28705&view=diff
==============================================================================
--- erp5/trunk/products/CMFActivity/tests/testCMFActivity.py [utf8] (original)
+++ erp5/trunk/products/CMFActivity/tests/testCMFActivity.py [utf8] Tue Sep  1 05:46:12 2009
@@ -3409,25 +3409,30 @@
                                                    offset=0,
                                                    count=1000)
 
-    self.assertEqual(len([message
-                          for message in result
-                          if (message.processing_node>0 and
-                              message.processing==1 and
-                              message.serialization_tag=='test_115')]),
-                     1)
-
-    self.assertEqual(len([message
-                          for message in result
-                          if (message.processing_node==-1 and
-                              message.serialization_tag=='test_115')]),
-                     3)
-
-    self.assertEqual(len([message
-                          for message in result
-                          if (message.processing_node>0 and
-                              message.processing==1 and
-                              message.serialization_tag=='')]),
-                     1)
+    try:
+      self.assertEqual(len([message
+                            for message in result
+                            if (message.processing_node>0 and
+                                message.processing==1 and
+                                message.serialization_tag=='test_115')]),
+                       1)
+
+      self.assertEqual(len([message
+                            for message in result
+                            if (message.processing_node==-1 and
+                                message.serialization_tag=='test_115')]),
+                       3)
+
+      self.assertEqual(len([message
+                            for message in result
+                            if (message.processing_node>0 and
+                                message.processing==1 and
+                                message.serialization_tag=='')]),
+                       1)
+    finally:
+      # Clear activities from all nodes
+      activity_tool.SQLDict_delMessage(uid=[message.uid for message in result])
+      get_transaction().commit()
 
 def test_suite():
   suite = unittest.TestSuite()