     :flow/exclude-keys [:extra-key]
     :flow/predicate :onyx.peer.colors-flow-test/orange?}
 
-   {:flow/from :colors-in
+   #_{:flow/from :colors-in
     :flow/to [:process-blue]
     :flow/exclude-keys [:extra-key]
     :flow/predicate :onyx.peer.colors-flow-test/orange?}


(close! colors-in-chan)

(doseq [v-peer v-peers]
  (onyx.api/shutdown-peer v-peer))

(onyx.api/shutdown-peer-group peer-group)

(onyx.api/shutdown-env env)


    :flow/exclude-keys [:extra-key]
    :flow/predicate :onyx.peer.colors-flow-test/red?}

   #_{:flow/from :colors-in
    :flow/to [:process-blue]
    :flow/short-circuit? true
    :flow/exclude-keys [:extra-key]
