diff --git a/product/CMFActivity/Activity/SQLQueue.py b/product/CMFActivity/Activity/SQLQueue.py index 9cc086092c5bab3660194ec1ab38125e05613b4d..f650429beb6b932d1d09a3a499f4aa563ef5e8ac 100644 --- a/product/CMFActivity/Activity/SQLQueue.py +++ b/product/CMFActivity/Activity/SQLQueue.py @@ -302,7 +302,6 @@ class SQLQueue(RAMQueue): return message_list def distribute(self, activity_tool, node_count): - processing_node = 1 readMessageList = getattr(activity_tool, 'SQLQueue_readMessageList', None) if readMessageList is not None: now_date = DateTime()