 (defn generate-join-entries [peer-ids]
   (zipmap peer-ids 
           (map (fn [id] [{:fn :prepare-join-cluster 
-                          :immediate? true
-                          :args {:peer-site (extensions/peer-site messenger)
-                                 :joiner id}}])
+                         :immediate? true
+                         :args {:peer-site (extensions/peer-site messenger)
+                                :joiner id}}])
                peer-ids)))
 
 (defn generate-peer-ids [n]

   :task-scheduler :onyx.task-scheduler/round-robin})

(def job-3-id #uuid "58d199e8-4ea4-4afd-a112-945e97235924")
(def job-3
  {:workflow [[:g :h] [:h :i]]
   :catalog [{:onyx/name :g

              :onyx/doc "Reads segments from a core.async channel"}

             {:onyx/name :e
              :onyx/fn :mock/fn
              :onyx/type :function
              :onyx/batch-size 20}

