    :task-scheduler :onyx.task-scheduler/round-robin})
 
 (def job-3-id #uuid "58d199e8-4ea4-4afd-a112-945e97235924")
+
 (def job-3
   {:workflow [[:g :h] [:h :i]]
    :catalog [{:onyx/name :g

(def messenger (->DummyMessenger))

(def job-1-id #uuid "f55c14f0-a847-42eb-81bb-0c0390a88608")
(def job-1
  {:workflow [[:a :b] [:b :c]]
   :catalog [{:onyx/name :a

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

             {:onyx/name :e
              :onyx/fn :mock/fn
              :onyx/type :function
              :onyx/batch-size 20}

