 
 (def wait-tries (Integer/parseInt (env :wait-tries "30")))
 (def wait-per-try (Integer/parseInt (env :wait-per-try "100")))
+(def wait-emit-msg (Integer/parseInt (env :wait-emit-msg "5000")))
+
+(def every-count-tries-emit (int (/ wait-emit-msg wait-per-try)))
 
 (defmacro is-submap
   [expected actual]

                                          :decode t/read-handlers}})]
       (if (= 404 (:status md))
         (do
           (Thread/sleep wait-per-try)
           (recur url (dec tries) md))
         md))
     last-result)))



(defn wait-for-url
  ([url]
   (wait-for-url url wait-tries 1 nil))
  ([url tries cnt last-result]
   (if (<= cnt tries)
     (let [md (client/get url
                          {:accept :transit+json
                           :as :stream
