                     :triggers triggers
                     :task-scheduler :onyx.task-scheduler/balanced})
               _ (onyx.test-helper/feedback-exception! peer-config (:job-id job))
-              results (take-segments! @out-chan 500000)]
+              results (take-segments! @out-chan 50)]
           (is (= (into #{} input) (into #{} results)))
           (is (= expected-windows @test-state))))))

            [onyx.api]))

(def input
  (map (fn [a]
         (assoc a 
                :randstuff
                (repeatedly 40
                            #(rand-int 256)))) 
       (reduce into [] 
               (repeat 30000
                       [{:id 1  :age 21 :event-time #inst "2015-09-13T03:00:00.829-00:00"}
                        {:id 2  :age 12 :event-time #inst "2015-09-13T03:04:00.829-00:00"}
                        {:id 3  :age 3  :event-time #inst "2015-09-13T03:05:00.829-00:00"}
                        {:id 4  :age 64 :event-time #inst "2015-09-13T03:06:00.829-00:00"}
                        {:id 5  :age 53 :event-time #inst "2015-09-13T03:07:00.829-00:00"}
                        {:id 6  :age 52 :event-time #inst "2015-09-13T03:08:00.829-00:00"}
                        {:id 7  :age 24 :event-time #inst "2015-09-13T03:09:00.829-00:00"}
                        {:id 8  :age 35 :event-time #inst "2015-09-13T03:15:00.829-00:00"}
                        {:id 9  :age 49 :event-time #inst "2015-09-13T03:25:00.829-00:00"}
                        {:id 10 :age 37 :event-time #inst "2015-09-13T03:45:00.829-00:00"}
                        {:id 11 :age 15 :event-time #inst "2015-09-13T03:03:00.829-00:00"}
                        {:id 12 :age 22 :event-time #inst "2015-09-13T03:56:00.829-00:00"}
                        {:id 13 :age 83 :event-time #inst "2015-09-13T03:59:00.829-00:00"}
                        {:id 14 :age 60 :event-time #inst "2015-09-13T03:32:00.829-00:00"}
                        {:id 15 :age 35 :event-time #inst "2015-09-13T03:16:00.829-00:00"}]))))

(def expected-windows
  [[1442113200000 1442113499999 

        [{:window/id :collect-segments
          :window/task :identity
          :window/type :fixed
          :window/aggregation :onyx.windowing.aggregation/conj
          :window/window-key :event-time
          :window/range [5 :minutes]}]
