diff --git a/product/CMFActivity/Activity/SQLBase.py b/product/CMFActivity/Activity/SQLBase.py
index 2e48d442778c284fbaf0763fab7d63714be9b133..bb90d6a7070fc19c119db740ede91cf23fa6cb2d 100644
--- a/product/CMFActivity/Activity/SQLBase.py
+++ b/product/CMFActivity/Activity/SQLBase.py
@@ -674,10 +674,9 @@ CREATE TABLE %s (
 
   def distribute(self, activity_tool, node_count):
     db = activity_tool.getSQLConnection()
-    now_date = getNow(db)
     where_kw = {
       'processing_node': -1,
-      'to_date': now_date,
+      'to_date': getNow(db),
       'count': READ_MESSAGE_LIMIT,
     }
     validated_count = 0