# 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