         :onyx/consumption :concurrent
         :onyx/batch-size batch-size}
 
-       {:onyx/name :inc
+       {:onyx/name :inc1
+        :onyx/fn :onyx-benchmark.peer/my-inc
+        :onyx/type :function
+        :onyx/consumption :concurrent
+        :onyx/batch-size batch-size}
+
+       {:onyx/name :inc2
+        :onyx/fn :onyx-benchmark.peer/my-inc
+        :onyx/type :function
+        :onyx/consumption :concurrent
+        :onyx/batch-size batch-size}
+       
+       {:onyx/name :inc3
+        :onyx/fn :onyx-benchmark.peer/my-inc
+        :onyx/type :function
+        :onyx/consumption :concurrent
+        :onyx/batch-size batch-size}
+
+       {:onyx/name :inc4
         :onyx/fn :onyx-benchmark.peer/my-inc
         :onyx/type :function
         :onyx/consumption :concurrent

(def lifecycles
  [{:lifecycle/task :in
    :lifecycle/calls :onyx-benchmark.peer/measurement-calls}
   {:lifecycle/task :inc
    :lifecycle/calls :onyx-benchmark.peer/measurement-calls}
   {:lifecycle/task :no-op
    :lifecycle/calls :onyx.plugin.core-async/writer-calls}

        :onyx/batch-size batch-size
        :onyx/doc "Drops messages on the floor"}])

    (def workflow [[:in :inc1] 
                   [:inc1 :inc2] 
                   [:inc2 :inc3]
                   [:inc3 :inc4]
                   [:inc4 :no-op]])

    (onyx.api/submit-job
     peer-config
