 (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 :b
              :onyx/fn :onyx.log.round-robin-multi-job-test/my-inc
              :onyx/type :function
              :onyx/batch-size 20}


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

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

