storage_participant.rb in ruote-2.1.6

- old
+ new

@@ -59,12 +59,10 @@
 
     def consume (workitem)
 
       doc = workitem.to_h
 
-      doc.delete('_rev')
-
       doc.merge!(
         'type' => 'workitems',
         '_id' => to_id(doc['fei']),
         'participant_name' => doc['participant_name'],
         'wfid' => doc['fei']['wfid'])
@@ -107,9 +105,11 @@
       doc = fetch(workitem.fei.to_h)
 
       r = @context.storage.delete(doc)
 
       return reply(workitem) if r != nil
+
+      workitem.h.delete('_rev')
 
       reply_to_engine(workitem)
     end
 
     # Returns the count of workitems stored in this participant.