# File lib/ruote/worker.rb, line 590 def respark(msg) wfid = msg['wfid'] opts = msg['respark'] ps = ProcessStatus.fetch(@context, [ wfid ], {}).first error_feis = ps.errors.collect(&:fei) errors_too = !! opts['errors_too'] ps.leaves.each do |fexp| next if errors_too == false && error_feis.include?(fexp.fei) @context.storage.put_msg( 'cancel', 'fei' => fexp.fei.h, 're_apply' => {}) end end