      (swap! retry-counter inc))})
 
 ;; :broken due of use of flow retry
-(deftest ^:smoke ^:broken colors-flow
+;; 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)

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

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


        lifecycles [{:lifecycle/task :colors-in
                     :lifecycle/calls :onyx.peer.colors-flow-test/colors-in-calls}
                    #_{: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}
