class Legion::Transport::Messages::TaskUpdate

Public Instance Methods

exchange() click to toggle source
# File lib/legion/transport/messages/task_update.rb, line 23
def exchange
  Legion::Transport::Exchanges::Task
end
routing_key() click to toggle source
# File lib/legion/transport/messages/task_update.rb, line 19
def routing_key
  'task.update'
end
valid_status() click to toggle source
# File lib/legion/transport/messages/task_update.rb, line 27
def valid_status
  conditioner = ['conditioner.queued', 'conditioner.failed', 'conditioner.exception']
  transformer = ['transformer.queued', 'transformer.succeeded', 'transformer.exception']
  task = ['task.scheduled', 'task.queued', 'task.completed', 'task.exception', 'task.delayed']
  conditioner + transformer + task
end