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