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

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

(def out-calls
  {:lifecycle/before-task-start inject-out-ch})

(deftest conj-test
  (let [id (random-uuid)
        config (load-config)
        env-config (assoc (:env-config config) :onyx/tenancy-id id)
        peer-config (assoc (:peer-config config) :onyx/tenancy-id id)
        batch-size 20
        workflow
        [[:in :identity] [:identity :out]]

