    UnsupportedWindowKey s/Any})
 
 (def Window
-  (s/constrained 
-    WindowBase
-    (fn [v] (if (#{:fixed :sliding} (:window/type v))
-              (:window/range v)
-              true))
-    ":window/range must be defined for :fixed or :sliding window"))
+  (s/constrained
+   WindowBase
+   (fn [v] (if (#{:fixed :sliding} (:window/type v))
+             (:window/range v)
+             true))
+   ":window/range must be defined for :fixed or :sliding window"))
 
 (def StateAggregationCall
   {(s/optional-key :aggregation/init) Function

                 #(= (:onyx/type %) :function)
                 FunctionTaskSchema))

(def Catalog
  [TaskMap])


                                  :else
                                  (merge base-output-schema partial-clojure-plugin)))))

(def FunctionTaskSchema
  (let [base-function-task (merge base-task-map partial-fn-task)
        java-function-task (merge base-function-task partial-grouping-task partial-java-fn-task)
