     :onyx/batch-size batch-size
     :onyx/doc "Drops messages on the floor"}])
 
-
-;; TO TEST
-
 (def workflow [[:in :inc1] 
                [:inc1 :inc2] 
                [:inc2 :inc3]
                [:inc3 :inc4]
                [:inc4 :no-op]])
 
-
-(println "starting Vpeers")
+(println "Starting Vpeers")
 (def v-peers (onyx.api/start-peers 6 peer-group))
 
 (println "Started vpeers")
-(def bench-length 300000)
+(def bench-length 120000)
 
 (def messages-tracking (atom {}))
 (def rate+latency (im/rate+latency {:rate-unit :nanoseconds 
                                     :latency-unit :nanoseconds}))
 (def retry-counter 
   (atom (long 0)))
+
+(def total-segments (atom 0))
 
 (Thread/sleep 10000)
 

                                                             (Thread/sleep 1000)
                                                             (.println (System/out) (str (:onyx.core/id event) " RATE: " (im/snapshot! rate)))))}))
   :lifecycle/after-batch (fn after-batch [event lifecycle]
                            (im/update! (:generator/rate event) (count (:onyx.core/batch event)))
                            {})})

(def in-calls 

            [onyx.plugin.bench-plugin]
            [onyx.static.logging-configuration :as log-config]
            [onyx.plugin.core-async]
            [onyx.test-helper :refer [load-config]]
            [interval-metrics.core :as im]
            [onyx.api])
  (:import [onyx.plugin RandomInputPlugin]))
