 (>!! in-chan :done)
 (close! in-chan)
 
-(def v-peers (onyx.api/start-peers 3 peer-group))
+(def v-peers (onyx.api/start-peers 4 peer-group))
 
 (onyx.api/submit-job
  peer-config


(fact results => [:done])

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

(onyx.api/shutdown-peer-group peer-group)

(onyx.api/shutdown-env env)


    :onyx/fn :onyx.peer.kw-grouping-test/sum-balance
    :onyx/type :function
    :onyx/group-by-key :name
    :onyx/min-peers 2
    :onyx/flux-policy :kill
    :onyx/batch-size 40}

