Commit 392dd9b2 authored by Jean-Paul Smets's avatar Jean-Paul Smets

start and stop commented out


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@709 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 04a15c45
...@@ -220,13 +220,13 @@ class SQLDict(RAMDict): ...@@ -220,13 +220,13 @@ class SQLDict(RAMDict):
raise ActivityFlushError, ( raise ActivityFlushError, (
'The document %s does not exist' % path) 'The document %s does not exist' % path)
def start(self, activity_tool, active_process=None): # def start(self, activity_tool, active_process=None):
uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) # uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process)
activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) # activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE)
def stop(self, activity_tool, active_process=None): # def stop(self, activity_tool, active_process=None):
uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) # uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process)
activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = STOP_STATE) # activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = STOP_STATE)
def getMessageList(self, activity_tool, processing_node=None): def getMessageList(self, activity_tool, processing_node=None):
# YO: reading all lines might cause a deadlock # YO: reading all lines might cause a deadlock
......
...@@ -164,13 +164,13 @@ class SQLQueue(RAMQueue): ...@@ -164,13 +164,13 @@ class SQLQueue(RAMQueue):
raise ActivityFlushError, ( raise ActivityFlushError, (
'The document %s does not exist' % path) 'The document %s does not exist' % path)
def start(self, activity_tool, active_process=None): # def start(self, activity_tool, active_process=None):
uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) # uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process)
activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) # activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE)
def stop(self, activity_tool, active_process=None): # def stop(self, activity_tool, active_process=None):
uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) # uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process)
activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = STOP_STATE) # activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = STOP_STATE)
def getMessageList(self, activity_tool, processing_node=None): def getMessageList(self, activity_tool, processing_node=None):
message_list = [] message_list = []
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment