 
         lifecycles [{:lifecycle/task :colors-in
                      :lifecycle/calls :onyx.peer.colors-flow-test/colors-in-calls}
-                    {:lifecycle/task :colors-in
+                    #_{:lifecycle/task :colors-in
                      :lifecycle/calls :onyx.peer.colors-flow-test/retry-calls}
                     {:lifecycle/task :red-out
                      :lifecycle/calls :onyx.peer.colors-flow-test/red-out-calls}

        (is (= red-expectations (into #{} red)))
        (is (= blue-expectations (into #{} blue)))
        (is (= all-expectations (into #{} all)))
        (is (= 1 @retry-counter)))

      (close! @colors-in-chan))))

     (swap! retry-counter inc))})

;; :broken due of use of flow retry
;; TODO, re-enable retries and tests
;; This test has been re-enabled to test flow conditions.
(deftest ^:smoke colors-flow
  (let [id (random-uuid)
        config (load-config)
        env-config (assoc (:env-config config) :onyx/tenancy-id id)
