lib/ruote/svc/tracker.rb
# Removes a set of tracker ids and updated the tracker document.
#
Removes a set of tracker ids and updated the tracker document.
Removes a set of tracker ids and updated the tracker document .
def remove(tracker_ids, wfid)
      return if tracker_ids.empty?
      doc ||= @context.storage.get_trackers(wfid)
      return if (doc['trackers'].keys & tracker_ids).empty?
      doc['wfid'] = wfid
      tracker_ids.each { |ti| doc['trackers'].delete(ti) }
      r = @context.storage.put(doc)
      remove(tracker_ids, wfid) if r
    end
def remove ( tracker_ids , wfid ) return if tracker_ids . empty? doc ||= @context . storage . get_trackers ( wfid ) return if ( doc [ 'trackers' ] . keys & tracker_ids ) . empty? doc [ 'wfid' ] = wfid tracker_ids . each { | ti | doc [ 'trackers' ] . delete ( ti ) } r = @context . storage . put ( doc ) remove ( tracker_ids , wfid ) if r end
Removes a set of tracker ids and updated the tracker document.
Removes a set of tracker ids and updated the tracker document .
# a little helper for some some storage implementations like ruote-swf # they need to know what workflow execution is targetted. # the put failed, have to redo the work
tracker_ids
wfid