 (deftest nil-flow-conditions
   "No flow condition routes to all downstream tasks"
   (let [downstream [:a :b]
-        route (t/route-data nil nil nil nil downstream)]
+        route (r/route-data nil nil nil nil downstream)]
     (is (= downstream (:flow route)))
     (is (nil? (:action route)))))
 

         downstream (mapcat :flow/to fcs)
         compiled (c/compile-fc-norms fcs :a)
         event {:onyx.core/compiled-norm-fcs compiled}
         results (t/route-data event nil nil fcs downstream)]
     (is (= (into #{} downstream) (into #{} (:flow/to results))))
     (is (nil? (:action results))))))


  (let [e (ex-info "hih" {})
        wrapped-e (ex-info "" {:exception e})]
    (is (thrown? clojure.lang.ExceptionInfo
                 (r/route-data nil nil wrapped-e nil [:a :b])))))

(deftest conj-downstream-tasks-together
  (checking
