    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

  ([peer-config monitoring-config]
   (validator/validate-peer-config peer-config)
   (let [id (java.util.UUID/randomUUID)
           client (component/start (system/onyx-client peer-config monitoring-config))
           entry (create-log-entry :gc {:id id})
           ch (chan 1000)]
       (extensions/write-log-entry (:log client) entry)

       (loop [replica (extensions/subscribe-to-log (:log client) ch)]
         (let [entry (<!! ch)
               new-replica (extensions/apply-log-entry entry replica)]
           (if (and (= (:fn entry) :gc) (= (:id (:args entry)) id))
             (let [diff (extensions/replica-diff entry replica new-replica)]
               (extensions/fire-side-effects! entry replica new-replica diff {:id id :log (:log client)}))
             (recur new-replica))))
       (component/stop client)
       true)))

(defn ^{:added "0.7.4"} await-job-completion
  "Blocks until job-id has had all of its tasks completed or the job is killed.
   Returns true if the job completed successfully, false if the job was killed."
  ([peer-config job-id]
     (await-job-completion peer-config job-id {:monitoring-config {:monitoring :no-op}}))
  ([peer-config job-id {:keys [monitoring-config timeout-ms]}]
   (validator/validate-peer-config peer-config)
   (let [job-id (validator/coerce-uuid job-id)

   convenient for directly querying the znodes. :env can be shutdown with
   the onyx.api/shutdown-env function"
  ([peer-config ch]
   (subscribe-to-log peer-config ch {:monitoring :no-op}))
  ([peer-config ch monitoring-config]
   (validator/validate-peer-config peer-config)
   (let [env (component/start (system/onyx-client peer-config monitoring-config))]
     {:replica (extensions/subscribe-to-log (:log env) ch)
      :env env})))

(defn ^{:added "0.6.0"} gc
  "Invokes the garbage collector on Onyx. Compresses all local replicas
