Revert "Fixes #464 - flow conditions :flow/from -> :all didn't compil…

…e properly." This reverts commit c421583.
onyx-platform · Dec 29, 2015 · 68b2f76 · 68b2f76
1 parent 1f054b4
commit 68b2f76
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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))]