lib/floe/workflow.rb in floe-0.15.0 vs lib/floe/workflow.rb in floe-0.15.1
- old
+ new
@@ -16,11 +16,10 @@
new(payload, context, credentials, name)
end
def wait(workflows, timeout: nil, &block)
workflows = [workflows] if workflows.kind_of?(self)
- logger.info("Checking #{workflows.count} workflows...")
run_until = Time.now.utc + timeout if timeout.to_i > 0
ready = []
queue = Queue.new
wait_thread = Thread.new do
@@ -70,10 +69,9 @@
end
ensure
sleep_thread&.kill
end
- logger.info("Checking #{workflows.count} workflows...Complete - #{ready.count} ready")
ready
ensure
wait_thread&.kill
end
end