lib/choria/orchestrator.rb in choria-colt-0.1.0 vs lib/choria/orchestrator.rb in choria-colt-0.1.1
- old
+ new
@@ -47,9 +47,10 @@
end
def wait_results(task_id:)
raise 'Task ID is required!' if task_id.nil?
+ task_status_results = nil
loop do
task_status_results = rpc_client.task_status(task_id: task_id).map(&:results)
logger.debug "Task ##{task_id} status: #{task_status_results}"
break if task_completed? task_status_results
end