 (doseq [v-peer v-peers]
   (onyx.api/shutdown-peer v-peer))
 
+(onyx.api/shutdown-peer-group peer-group)
+
 (onyx.api/shutdown-env env)
 

    :onyx.peer/job-scheduler :onyx.job-scheduler/round-robin))

(def env (onyx.api/start-env env-config))

(def output (atom []))


(>!! in-chan :done)
(close! in-chan)

(def v-peers (onyx.api/start-peers 3 peer-group))

(onyx.api/submit-job
 peer-config
