    a 3rd argument - a monitoring configuration map. See the User Guide
    for details."
   ([n peer-group]
-     (start-peers n peer-group {:monitoring :no-op}))
+   (start-peers n peer-group {:monitoring :no-op}))
   ([n {:keys [config] :as peer-group} monitoring-config]
-     (when-not (= (type peer-group) onyx.system.OnyxPeerGroup)
-       (throw (Exception. (str "start-peers must supplied with a peer-group not a " (type peer-group)))))
-     (validator/validate-java-version)
-     (doall
-      (map
-       (fn [_]
-         (let [v-peer (system/onyx-peer peer-group monitoring-config)
-               live (component/start v-peer)
-               shutdown-ch (chan 1)
-               ack-ch (chan)
-               started-peer (atom live)]
-           {:peer-lifecycle (future (peer-lifecycle started-peer config shutdown-ch ack-ch))
-            :started-peer started-peer
-            :shutdown-ch shutdown-ch
-            :ack-ch ack-ch}))
-       (range n)))))
+   (when-not (= (type peer-group) onyx.system.OnyxPeerGroup)
+     (throw (Exception. (str "start-peers must supplied with a peer-group not a " (type peer-group)))))
+   (validator/validate-java-version)
+   (doall
+    (map
+     (fn [_]
+       (let [v-peer (system/onyx-peer peer-group monitoring-config)
+             live (component/start v-peer)
+             shutdown-ch (chan 1)
+             ack-ch (chan)
+             started-peer (atom live)]
+         {:peer-lifecycle (future (peer-lifecycle started-peer config shutdown-ch ack-ch))
+          :started-peer started-peer
+          :shutdown-ch shutdown-ch
+          :ack-ch ack-ch}))
+     (range n)))))
 
 (defn ^{:added "0.6.0"} shutdown-peer
   "Shuts down the virtual peer, which releases all of its resources

(defn ^{:added "0.6.0"} start-env
  "Starts a development environment using an in-memory implementation ZooKeeper."
  ([env-config]
     (start-env env-config {:monitoring :no-op}))
  ([env-config monitoring-config]
   (validator/validate-env-config env-config)
   (component/start (system/onyx-development-env env-config monitoring-config))))

  "Takes a peer configuration, job map, and optional monitoring config,
   sending the job to the cluster for eventual execution."
  ([peer-config job]
   (submit-job peer-config job {:monitoring :no-op}))
  ([peer-config job monitoring-config]
   (try (validator/validate-peer-config peer-config)
        (validator/validate-job (assoc job :workflow (:workflow job)))
        (validator/validate-flow-conditions (:flow-conditions job) (:workflow job))
        (validator/validate-lifecycles (:lifecycles job) (:catalog job))
        (validator/validate-windows (:windows job) (:catalog job))
        (validator/validate-triggers (:triggers job) (:windows job))
        (catch Throwable t
          (error t)
          (throw t)))
   (let [id (java.util.UUID/randomUUID)
         tasks (planning/discover-tasks (:catalog job) (:workflow job))
         entry (create-submit-job-entry id peer-config job tasks)
         client (component/start (system/onyx-client peer-config monitoring-config))]
     (extensions/write-chunk (:log client) :catalog (:catalog job) id)
     (extensions/write-chunk (:log client) :workflow (:workflow job) id)
     (extensions/write-chunk (:log client) :flow-conditions (:flow-conditions job) id)
     (extensions/write-chunk (:log client) :lifecycles (:lifecycles job) id)
     (extensions/write-chunk (:log client) :windows (:windows job) id)
     (extensions/write-chunk (:log client) :triggers (:triggers job) id)

     (doseq [task tasks]
       (extensions/write-chunk (:log client) :task task id))

     (extensions/write-log-entry (:log client) entry)
     (component/stop client)
     {:job-id id
      :task-ids (zipmap (map :name tasks) tasks)})))

(defn ^{:added "0.6.0"} kill-job
  "Kills a currently executing job, given it's job ID. All peers executing
