         q (build-watch-query env opts)
         q (if v (assoc-in q [:query :resourceVersion] v) q)
         on-change (mk-on-change env opts #(do-watch env client opts))]
-    (println "Watch " opts " from " v)
+    #_(println "Start Watch " opts " from " v)
+    (println "Start Watch ")
     (->> (http/request-stream client :get (:url q) on-change
                               :headers {"Authorization" (str "Bearer " (:kube-token env))}
                               :insecure? true

                  (do #_(println "ERRORED:" opts)
                      (#'do-watch env client (dissoc opts :request)))
                  (realized? (:done req))
                  (do (println "DONE:" opts)
                      (#'do-watch env client (dissoc opts :request))))))
        (Thread/sleep 10000)))
    (println "Stopping supervisor")

    (let [[json-str rest-msg] (str/split s #"\n" 2)]
      (try (*parse-json-stream (conj acc (json/parse-string json-str keyword)) rest-msg)
           (catch com.fasterxml.jackson.core.JsonParseException e
             #_(println "JSON ERROR WHILE PARSE" s)
             [s acc])))
    [s acc]))

