                       :hornetq/queue-name "out-queue"}]
             workflow {:in {:inc :out}}
             offer-ch-spy (chan 1)]
-        (tap (:offer-mult coordinator) offer-ch-spy)
+        
+        (tap (:offer-mult coordinator) offer-ch-spy)
+        
         (>!! (:planning-ch-head coordinator)
              {:catalog catalog :workflow workflow})
 

              db (d/db (:conn log))]

          (testing "There is one job"
              (let [query '[:find ?j :in $ ?id :where [?j :job/id ?id]]
                    result (d/q query db job-id)]
                (is (= (count result) 1))))

          (testing "There are three tasks")
          (let [query '[:find ?n :where [?t :task/name ?n]]
                result (d/q query db)]
            (is (= result #{[:in] [:inc] [:out]})))

          (testing ":in's ingress queue is preset"
            (let [query '[:find ?qs :where

                  result (d/q query db)]
              (is (empty? result))))

          (testing ":inc's ingress queue is :in's egress queue"
            (let [in-query '[:find ?qs :where
                             [?t :task/name :in]
                             [?t :task/egress-queues ?qs]]
                  inc-query '[:find ?qs :where
                              [?t :task/name :inc]
                              [?t :task/ingress-queues ?qs]]]
              (is (= (d/q in-query db) (d/q inc-query db)))))

          (testing ":out's ingess queue is :inc's egress queue"
            (let [inc-query '[:find ?qs :where
