   (def workflow-2 [[:in-2 :inc] [:inc :out-2]])
 
   (defn inject-in-1-ch [event lifecycle]
-    {:core.async/chan in-1-chan})
+    {:core.async/chan in-chan-1})
 
   (defn inject-in-2-ch [event lifecycle]
-    {:core.async/chan in-2-chan})
+    {:core.async/chan in-chan-2})
 
   (defn inject-out-1-ch [event lifecycle]
-    {:core.async/chan out-1-chan})
+    {:core.async/chan out-chan-1})
 
   (defn inject-out-2-ch [event lifecycle]
-    {:core.async/chan out-2-chan})
+    {:core.async/chan out-chan-2})
 
   (def in-1-calls
     {:lifecycle/before-task :onyx.peer.killed-job-test/inject-in-1-ch})


(def n-messages 15000)

(def batch-size 1320)

(def env-config (assoc (:env-config config) :onyx/id id))


     (onyx.api/shutdown-peer v-peer))

   (onyx.api/shutdown-peer-group peer-group)

   (onyx.api/shutdown-env env)))
