From 545031b510ae5ba914758c6e2a2261031772c1f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aur=C3=A9lien=20Calonne?= <aurel@nexedi.com> Date: Wed, 7 Mar 2007 08:19:48 +0000 Subject: [PATCH] delete message for the method id given in parameter to flush git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@13243 20353a03-c40f-0410-a6d1-a30d3c3de9de --- product/CMFActivity/Activity/SQLDict.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/product/CMFActivity/Activity/SQLDict.py b/product/CMFActivity/Activity/SQLDict.py index ffe1530c48..9484597af4 100644 --- a/product/CMFActivity/Activity/SQLDict.py +++ b/product/CMFActivity/Activity/SQLDict.py @@ -423,12 +423,12 @@ class SQLDict(RAMDict): processing_node=None,include_processing=0) for line in result: path = line.path - method_id = line.method_id - if not method_dict.has_key(method_id): + line_method_id = line.method_id + if not method_dict.has_key(line_method_id): # Only invoke once (it would be different for a queue) # This is optimisation with the goal to process objects on the same # node and minimize network traffic with ZEO server - method_dict[method_id] = 1 + method_dict[line_method_id] = 1 m = self.loadMessage(line.message, uid = line.uid) if invoke: # First Validate @@ -450,7 +450,7 @@ class SQLDict(RAMDict): 'Could not validate %s on %s' % (m.method_id , path)) if len(result): - uid_list = activity_tool.SQLDict_readUidList(path = path, method_id = None, + uid_list = activity_tool.SQLDict_readUidList(path = path, method_id = method_id, processing_node = None,) activity_tool.SQLDict_delMessage(uid = [x.uid for x in uid_list]) -- 2.30.9