Sha256: a08fa550426b5e2bc14c0c02fd68dc4287ff55dd284c8b9ef61f8a91496a969c
Contents?: true
Size: 796 Bytes
Versions: 9
Compression:
Stored size: 796 Bytes
Contents
require 'legion/transport/exchanges/task'
module Legion
module Exception
class InvalidTaskStatus; end
class InvalidTaskId; end
end
end
module Legion
module Transport
module Messages
class TaskUpdate < Legion::Transport::Message
def routing_key
'task.update'
end
def exchange
Legion::Transport::Exchanges::Task
end
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
end
end
end
end
Version data entries
9 entries across 9 versions & 2 rubygems