From 68b2f76e9b29d825517f11e9f9fea5d722439ee5 Mon Sep 17 00:00:00 2001 From: Michael Drogalis Date: Tue, 29 Dec 2015 15:49:42 -0800 Subject: [PATCH] Revert "Fixes #464 - flow conditions :flow/from -> :all didn't compile properly." This reverts commit c4215838a288d19df5defd90ab518df19e3fa1f3. --- src/onyx/peer/task_compile.clj | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/onyx/peer/task_compile.clj b/src/onyx/peer/task_compile.clj index 446688e4f..2829f9cf5 100644 --- a/src/onyx/peer/task_compile.clj +++ b/src/onyx/peer/task_compile.clj @@ -9,7 +9,7 @@ [clj-tuple :as t])) (defn only-relevant-branches [flow task] - (filter #(or (= (:flow/from %) task) (= :all (:flow/from %))) flow)) + (filter #(or (= (:flow/from %) task) (= :all %)) flow)) (defn compile-flow-conditions [flow-conditions task-name f] (let [conditions (filter f (only-relevant-branches flow-conditions task-name))]