     :onyx/batch-size batch-size
     :onyx/doc "Writes segments to a core.async channel"}])
 
-(def workflow [[:in :inc] [:inc :out]])
+(def workflow [[:in :intermediate-1] 
+               [:intermediate-1 :intermediate-2] 
+               [:intermediate-2 :out]])
 
 (def chan-size 10000)
 

      (fact after-done => #{}))

    (close! kill-ch)
    (helper-env/remove-n-peers test-env 9))

    (finally 

    :onyx/batch-size batch-size
    :onyx/doc "Reads segments from a core.async channel"}

   {:onyx/name :intermediate-1
    :onyx/fn :onyx.peer.fault-tolerance/process-middle
    :onyx/type :function
    :onyx/batch-size batch-size}

   {:onyx/name :intermediate-2
    :onyx/fn :onyx.peer.fault-tolerance/process-middle
    :onyx/type :function
    :onyx/batch-size batch-size}
