   (:require [onyx.peer.pipeline-extensions :as p-ext]
             [onyx.peer.task-lifecycle-extensions :as l-ext]
             [midje.sweet :refer :all]
-            [onyx.queue.hornetq-utils :as hq-util]
             [onyx.api]))
 
 (def id (java.util.UUID/randomUUID))

             [:b :d]
             [:c :d]
             [:c :e]]))


(fact (into #{} (onyx.api/unpack-map-workflow {:a {:b :c} :d {:e :f :g :h}}))
      => #{[:a :b]
           [:b :c]
           [:d :e]
           [:d :g]
           [:e :f]
           [:g :h]})

(let [catalog
      [{:onyx/name :a


(onyx.api/shutdown-env env)

(fact (sort (onyx.api/map-set-workflow->workflow {:a #{:b :c}
                                                  :b #{:d}
                                                  :c #{:d :e}}))
