Class: Conflow::Redis::CompleteJobScript

Inherits:

Script

• Object
• Script
• Conflow::Redis::CompleteJobScript

Defined in:

lib/conflow/redis/complete_job_script.rb

Overview

Adds new job to flow

Class Method Summary

• .call(flow, job) ⇒ Object

  Call the script.

Methods inherited from Script

inherited

Class Method Details

.call(flow, job) ⇒ Object

Call the script. Script changes Flow#indegree of all of its successors by -1 (freeing them to be queued if it reaches 0) and sets Job#status to 1 (finished)

Parameters:

• flow (Conflow::Flow) —

  Flow to which job belongs to

• job (Conflow::Job) —

  Job to be marked as completed

# File 'lib/conflow/redis/complete_job_script.rb', line 29

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