 
 ;; TO TEST
 
-(defn inject-no-op-ch [event lifecycle]
-  {:core.async/chan (chan (dropping-buffer 1))})
+(def workflow [[:in :inc1] 
+               [:inc1 :inc2] 
+               [:inc2 :inc3]
+               [:inc3 :inc4]
+               [:inc4 :no-op]])
 
-(def workflow [[:in :inc] [:inc :no-op]])
 
-(println "Starting env")
-(def env (onyx.api/start-env env-config))
 (println "starting Vpeers")
+(def v-peers (onyx.api/start-peers 6 peer-group))
 
-(def v-peers (onyx.api/start-peers 6 peer-group))
 (println "Started vpeers")
-
-(def bench-length 100000)
+(def bench-length 300000)
 
 (Thread/sleep 10000)
 

    :onyx/batch-timeout batch-timeout
    :onyx/batch-size batch-size}

   {:onyx/name :inc
    :onyx/fn :onyx.plugin.bench-plugin-test/my-inc
    :onyx/type :function
    :onyx/batch-timeout batch-timeout


(future
  (while true 
    (println "Retry counter " @retry-counter)
    (println "Update " @counter (float (/ @counter
                                          (/ (- (System/currentTimeMillis) start-time-millis) 
                                             1000))) "/sec")
