                      :onyx.messaging/peer-ports (vec (range 40000 40200))
                      :onyx.peer/join-failure-back-off 500
                      :onyx.peer/job-scheduler :onyx.job-scheduler/greedy
+                     :onyx.peer/inbox-capacity 100
                      :onyx.messaging/impl :netty
                      :onyx.log/config logging-config}
         n-peers-parsed (Integer/parseInt n-peers)

  {:core.async/chan (chan (dropping-buffer 1))})

(def counter (atom 0))

(defn close-batch-inc
  [event _]


(defn inject-state
  [event _]
  {:retry-counter retry-counter
   :bench/state counter})

(def no-op-calls 
  {:lifecycle/before-task inject-no-op-ch})
