    [:process-green :green-out]])
 
 (def flow-conditions
-  [{:flow/from :in
+  [{:flow/from :people-in
     :flow/to [:process-children]
     :child/age 17
     :flow/predicate [:onyx.peer.flow-test/child? :child/age]}
 
-   {:flow/from :in
+   {:flow/from :people-in
     :flow/to [:process-adults]
     :flow/predicate :onyx.peer.flow-test/adult?}
 
-   {:flow/from :in
+   {:flow/from :people-in
     :flow/to [:process-athletes-in-washington]
     :flow/predicate [:and :onyx.peer.flow-test/athlete? :onyx.peer.flow-test/washington-resident?]}
 
-   {:flow/from :in
+   {:flow/from :people-in
     :flow/to [:process-everyone]
     :flow/predicate :onyx.peer.flow-test/constantly-true}
 

    :hornetq/queue-name blue-out-queue
    :hornetq/host (:host (:non-clustered (:hornetq config)))
    :hornetq/port (:port (:non-clustered (:hornetq config)))
    :onyx/batch-size batch-size}]

  {:onyx/name :green-out
   :onyx/ident :hornetq/write-segments
   :onyx/type :output
   :onyx/medium :hornetq
   :onyx/consumption :concurrent
   :hornetq/queue-name green-out-queue
   :hornetq/host (:host (:non-clustered (:hornetq config)))
   :hornetq/port (:port (:non-clustered (:hornetq config)))
   :onyx/batch-size batch-size})

(def workflow
  [[:people-in :process-children]

(defn process-blue [segment]
  (assoc segment :extra-key "Some extra context for the predicates"))

(defn process-green [segment]
  (assoc segment :extra-key "Some extra context for the predicates"))

(def v-peers (onyx.api/start-peers! 1 peer-config))
