class

Kiq::PipelineStatus

Redis-backed pipeline/node status store — 1:1 with Sidekiq::PipelineStatus.

Class methods

all_node_statuses(pipeline_name : String) : Hash(String, String)

array_of_strings(v) : Array(String)

completed_nodes_count(pipeline_name : String) : Int32

find_node_by_bid(bid : String) : Tuple(String, String) | Nil | Hash(String, String) | Nil

finish!(pipeline_name : String, success : Bool = true) : Nil

hash_of_strings(v) : Hash(String, String)

node_bid(pipeline_name : String, node_name : String) : String | Nil

node_complete!(pipeline_name : String, node_name : String) : Nil

node_fail!(pipeline_name : String, node_name : String, error : String | Nil = nil) : Nil

node_progress(pipeline_name : String, node_name : String) : Hash(String, Arg) | Nil

node_start!(pipeline_name : String, node_name : String, bid : String | Nil = nil) : Nil

node_status(pipeline_name : String, node_name : String) : String

redis

reset!(pipeline_name : String) : Nil

running?(pipeline_name : String) : Bool

running_node_ids(pipeline_name : String) : Array(String)

save_bid!(pipeline_name : String, node_name : String, bid : String | Nil) : Nil

start!(pipeline_name : String) : Nil