Class: Conflow::Redis::QueueJobsScript Private

Inherits:

Script

• Object
• Script
• Conflow::Redis::QueueJobsScript

Defined in:

lib/conflow/redis/queue_jobs_script.rb

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

Removes jobs from indegree set, adds them to queued list, and returns IDs of queued jobs.

Class Method Summary

• .call(flow) ⇒ Object private

  Call the script.

Methods inherited from Script

inherited

Class Method Details

.call(flow) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Call the script. Script removes jobs which have score 0 in Flow’s indegree set and moves them to queued_jobs list.

# File 'lib/conflow/redis/queue_jobs_script.rb', line 26

def call(flow)
  super([flow.indegree.key, flow.queued_jobs.key])
end