class Sidekiq::Hierarchy::Observers::WorkflowUpdate

Public Instance Methods

call(workflow, status, old_status) click to toggle source
# File lib/sidekiq/hierarchy/observers/workflow_update.rb, line 9
def call(workflow, status, old_status)
  from_set = WorkflowSet.for_status(old_status)
  to_set = WorkflowSet.for_status(status)

  to_set.move(workflow, from_set)  # Move/add to the new status set
end
register(callback_registry) click to toggle source
# File lib/sidekiq/hierarchy/observers/workflow_update.rb, line 5
def register(callback_registry)
  callback_registry.subscribe(Notifications::WORKFLOW_UPDATE, self)
end