class Sidekiq::Work
Sidekiq::Work represents a job which is currently executing.
def initialize(pid, tid, hsh)
def initialize(pid, tid, hsh) @process_id = pid @thread_id = tid @hsh = hsh @job = nil end
def job
def job @job ||= Sidekiq::JobRecord.new(@hsh["payload"]) end
def payload
def payload @hsh["payload"] end
def queue
def queue @hsh["queue"] end
def run_at
def run_at Time.at(@hsh["run_at"]) end