Commit f09e1a36 authored by Vincent Pelletier's avatar Vincent Pelletier

CMFActivity.Activity.SQLBase: Properly release reserved messages when load raises.

Seen happen on SQLDict with 94 indexation activities being stuck assigned
to a processing node on which load failed because of an SQL deadlock.
parent 5c0a852e
......@@ -550,6 +550,9 @@ CREATE TABLE %s (
1, node_set=node_family_id_list)
if not result:
break
# So reserved documents are properly released even if load raises.
for line in result:
uid_to_duplicate_uid_list_dict[line.uid] = []
load = self.getProcessableMessageLoader(db, processing_node)
m, uid, uid_list = load(result[0])
message_list = [m]
......
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