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

(ns onyx.windowing.aggregation-conj-test
  (:require [clojure.core.async :refer [chan >!! <!! close! sliding-buffer dropping-buffer]]
            [clojure.test :refer [deftest is]]
            [onyx.plugin.core-async :refer [take-segments!]]
            [schema.core :as s]

                      trigger :- os/Trigger 
                      {:keys [lower-bound upper-bound event-type] :as state-event} :- os/StateEvent 
                      extent-state]
  (when-not (= :job-completed event-type)
    (swap! test-state conj [lower-bound upper-bound extent-state])))

