def continue
      return if self.finished? || !self.valid? || !self.paused?
      if @flow_data.decr(:paused) == 0
        workers = Hash[self.counters.select { |name, _| !self.class.terminal?(name) && name != :processing }]

        # enqueue jobs
        workers.each { |worker, num_objects| create_jobs(worker, num_objects) }
      end
    rescue StandardError => e
      Rails.logger.error("Error continuing flow #{self.id}: #{e.message}")
    end
def continue
      return if self.finished? || !self.valid? || !self.paused?
      if @flow_data.decr(:paused) == 0
        workers = Hash[self.counters.select { |name, _| !self.class.terminal?(name) && name != :processing }]

        # enqueue jobs
        workers.each { |worker, num_objects| create_jobs(worker, num_objects) }
      end
    rescue StandardError => e
      Rails.logger.error("Error continuing flow #{self.id}: #{e.message}")
    end
for now assumes