##// END OF EJS Templates
add missing buffers to resubmitted tasks...
MinRK -
Show More
@@ -1163,7 +1163,7 b' class Hub(SessionFactory):'
1163 1163 # send the messages
1164 1164 for rec in records:
1165 1165 header = rec['header']
1166 msg = self.session.msg(header['msg_type'])
1166 msg = self.session.msg(header['msg_type'], parent=header)
1167 1167 msg_id = msg['msg_id']
1168 1168 msg['content'] = rec['content']
1169 1169
@@ -1177,7 +1177,7 b' class Hub(SessionFactory):'
1177 1177
1178 1178 resubmitted[rec['msg_id']] = msg_id
1179 1179 self.pending.add(msg_id)
1180 msg['buffers'] = []
1180 msg['buffers'] = rec['buffers']
1181 1181 try:
1182 1182 self.db.add_record(msg_id, init_record(msg))
1183 1183 except Exception:
General Comments 0
You need to be logged in to leave comments. Login now