Method: Conflow::Redis::QueueJobsScript.call

Defined in:
lib/conflow/redis/queue_jobs_script.rb

.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.

Parameters:

  • flow (Conflow::Flow) —

    Flow from which jobs should be enqueued



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

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