Method: Lowkiq::Queue::Queue#processing_data

Defined in:
lib/lowkiq/queue/queue.rb

#processing_data(shard) ⇒ Object 



122
123
124
125
126
127
128
129
130
131
132
133
 
# File 'lib/lowkiq/queue/queue.rb', line 122

def processing_data(shard)
  @pool.with do |redis|
    ids = redis.hkeys @keys.processing_ids_with_perform_in_hash(shard)
    return [] if ids.empty?

    res = redis.multi do |redis|
      processing_data_pipeline redis, shard, ids
    end

    processing_data_build res, ids
  end
end