             [clojure.core.async :refer [chan >!! <!!]]
             [com.stuartsierra.component :as component]
             [clj-http.client :refer [post]]
-            [taoensso.timbre :refer [info]]
+            [taoensso.timbre :refer [warn]]
             [onyx.coordinator.impl :as impl]
             [onyx.system :as system]
             [onyx.extensions :as extensions]))

          true
          (do (<!! ch)
              (recur)))))))

;; A coordinator that runs strictly in memory. Peers communicate with
;; the coordinator by directly accessing its channels.

  (doall
   (map
    (fn [_]
      (let [v-peer (try-start-peer* (system/onyx-peer config) config)]
        (let [rets {:runner (future
                              (try @(:payload-thread (:peer v-peer))
                                   (catch Exception e
                                     (warn e))))
                    :shutdown-fn (fn [] (component/stop v-peer))}]
          (register-peer coord (:node (:peer (:peer v-peer))))
          rets)))
