 
 ;; 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)
 


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

(def scheduler :onyx.job-scheduler/greedy)

(def messaging :netty)
;(def messaging :aleph-tcp)
;(def messaging :netty-tcp)

(def env-config
  {:zookeeper/address "127.0.0.1:2189"


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