       :onyx/type :function
       :onyx/batch-size batch-size}
 
-     {:onyx/name :out-2
+     {:onyx/name :out-1
       :onyx/ident :core.async/write-to-chan
       :onyx/type :output
       :onyx/medium :core.async

      :onyx/max-peers 1
      :onyx/doc "Writes segments to a core.async channel"}])

  (def workflow-1 [[:in-1 :inc] [:inc :out-1]])

  (def workflow-2 [[:in-2 :inc] [:inc :out-2]])

  (def v-peers (onyx.api/start-peers! 1 peer-group))

  (def j1 (onyx.api/submit-job
            peer-config
            {:catalog catalog-1 :workflow workflow-1
             :task-scheduler :onyx.task-scheduler/balanced}))

  (def j2 (onyx.api/submit-job
            peer-config
            {:catalog catalog-2 :workflow workflow-2
             :task-scheduler :onyx.task-scheduler/balanced}))

  (onyx.api/kill-job peer-config (:job-id j1))

  (def results (take-segments! out-chan-2))


            [onyx.peer.task-lifecycle-extensions :as l-ext]
            [onyx.plugin.core-async :refer [take-segments!]]
            [onyx.test-helper :refer [load-config]]
            [onyx.extensions :as extensions]
            [onyx.api]))

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