     (reset! in-chan (chan (inc (count input))))
     (reset! in-buffer {})
     (reset! out-chan (chan (sliding-buffer (inc (count input)))))
+    (reset! fire-count {})
     (reset! test-state {})
 
     (with-test-env [test-env [5 env-config peer-config]]

                                                   :lifecycles lifecycles
                                                   :windows windows
                                                   :triggers triggers
                                                   :task-scheduler :onyx.task-scheduler/balanced})]
        (doseq [i input]
          (Thread/sleep 500)
          (>!! @in-chan i))
        (close! @in-chan)
        (let [_ (onyx.test-helper/feedback-exception! peer-config job-id)
              results (take-segments! @out-chan 50)]
          (is (#{2 3} (apply max (vals @fire-count))))
          (is (= (into #{} input) (into #{} results)))
          (is (= expected-windows @test-state)))))))

          :trigger/id :sync
          :trigger/refinement :onyx.refinements/accumulating
          :trigger/fire-all-extents? true
          :trigger/on :onyx.triggers/timer
          :trigger/period [1 :seconds]
          :trigger/sync ::update-atom!}]
