class ActiveJobStatus::JobTracker

Constants

DEFAULT_EXPIRATION

Attributes

expiration[R]
job_id[R]
store[R]

Public Class Methods

new(job_id:, store: ActiveJobStatus.store, expiration: ActiveJobStatus.expiration) click to toggle source
# File lib/active_job_status/job_tracker.rb, line 5
def initialize(job_id:, store: ActiveJobStatus.store, expiration: ActiveJobStatus.expiration)
  @job_id = job_id
  @store = store
  @expiration = expiration
end

Public Instance Methods

completed() click to toggle source
# File lib/active_job_status/job_tracker.rb, line 26
def completed
  store.write(
    job_id,
    JobStatus::COMPLETED.to_s
  )
end
deleted() click to toggle source
# File lib/active_job_status/job_tracker.rb, line 33
def deleted
  store.delete(job_id)
end
enqueued() click to toggle source
# File lib/active_job_status/job_tracker.rb, line 11
def enqueued
  store.write(
    job_id,
    JobStatus::ENQUEUED.to_s,
    expires_in: expiration || DEFAULT_EXPIRATION
  )
end
performing() click to toggle source
# File lib/active_job_status/job_tracker.rb, line 19
def performing
  store.write(
    job_id,
    JobStatus::WORKING.to_s
  )
end