 
 (def green-out-chan (chan (sliding-buffer 100)))
 
-(doseq [x [{:color "red" :extra-key "Some extra context for the predicates"}
-           {:color "blue" :extra-key "Some extra context for the predicates"}
+(doseq [x [;;{:color "red" :extra-key "Some extra context for the predicates"}
+           ;;{:color "blue" :extra-key "Some extra context for the predicates"}
            {:color "white" :extra-key "Some extra context for the predicates"}
-           {:color "green" :extra-key "Some extra context for the predicates"}
-           {:color "orange" :extra-key "Some extra context for the predicates"}
-           {:color "black" :extra-key "Some extra context for the predicates"}
-           {:color "purple" :extra-key "Some extra context for the predicates"}
-           {:color "cyan" :extra-key "Some extra context for the predicates"}
-           {:color "yellow" :extra-key "Some extra context for the predicates"}]]
+           ;;{:color "green" :extra-key "Some extra context for the predicates"}
+           ;;{:color "orange" :extra-key "Some extra context for the predicates"}
+           ;;{:color "black" :extra-key "Some extra context for the predicates"}
+           ;;{:color "purple" :extra-key "Some extra context for the predicates"}
+           ;;{:color "cyan" :extra-key "Some extra context for the predicates"}
+           ;;{:color "yellow" :extra-key "Some extra context for the predicates"}
+           ]]
   (>!! colors-in-chan x))
 
 (>!! colors-in-chan :done)

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

   {: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)

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

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

  (onyx.api/shutdown-env env))

