   (: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))


(onyx.api/shutdown-env env)

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

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

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

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