Sha256: 51c584f46f5216c80bd1e8d5c05b9836b1e7bb67e1642a0c73a932e40be81595
Contents?: true
Size: 1.13 KB
Versions: 16
Compression:
Stored size: 1.13 KB
Contents
module Sidekiq::Status::Worker
include Sidekiq::Status::Storage
class Stopped < StandardError
end
attr_accessor :expiration
# Stores multiple values into a job's status hash,
# sets last update time
# @param [Hash] status_updates updated values
# @return [String] Redis operation status code
def store(hash)
store_for_id @provider_job_id || @job_id || @jid, hash, @expiration
end
# Read value from job status hash
# @param String|Symbol hask key
# @return [String]
def retrieve(name)
read_field_for_id @provider_job_id || @job_id || @jid, name
end
# Sets current task progress
# (inspired by resque-status)
# @param Fixnum number of tasks done
# @param String optional message
# @return [String]
def at(num, message = nil)
@_status_total = 100 if @_status_total.nil?
pct_complete = ((num / @_status_total.to_f) * 100).to_i rescue 0
store(at: num, total: @_status_total, pct_complete: pct_complete, message: message)
end
# Sets total number of tasks
# @param Fixnum total number of tasks
# @return [String]
def total(num)
@_status_total = num
store(total: num)
end
end
Version data entries
16 entries across 16 versions & 1 rubygems