Revision add80afa
Added by Lukas Zapletal over 7 years ago
| app/models/concerns/orchestration.rb | ||
|---|---|---|
|
fail_queue(q)
|
||
|
|
||
|
rollback
|
||
|
ensure
|
||
|
unless q.nil?
|
||
|
logger.info("Processed queue '#{queue_name}', #{q.completed.count}/#{q.all.count} completed tasks") unless q.empty?
|
||
|
q.all.each do |task|
|
||
|
msg = "Task #{task.name} *#{task.status}*"
|
||
|
if task.status?(:completed) || task.status?(:pending)
|
||
|
logger.debug msg
|
||
|
else
|
||
|
logger.error msg
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def fail_queue(q)
|
||
| app/services/orchestration/task.rb | ||
|---|---|---|
|
end
|
||
|
end
|
||
|
|
||
|
def status?(symbol)
|
||
|
@status == symbol.to_s
|
||
|
end
|
||
|
|
||
|
def to_s
|
||
|
"#{name}\t #{priority}\t #{status}\t #{action}"
|
||
|
end
|
||
Also available in: Unified diff
Fixes #17042 - add logging of task statuses after orchestration
(cherry picked from commit 2f7a49850c36d5a4ce06e9f8b2fe891c78434238)