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