 (def env (onyx.api/start-env env-config))
 
 (def peer-group (onyx.api/start-peer-group peer-config))
-
 (def batch-size 2)
 
 (def people

  [_ event]
  {:onyx.core/params [(atom {})]})

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

(onyx.api/submit-job

            [onyx.peer.task-lifecycle-extensions :as l-ext]
            [onyx.plugin.core-async :refer [take-segments!]]
            [onyx.test-helper :refer [load-config]]
            [onyx.api]
            [taoensso.timbre :refer [info warn trace fatal] :as timbre]))

(def id (java.util.UUID/randomUUID))

