 (def partial-output-task
   {:onyx/plugin NamespacedKeyword
    :onyx/medium s/Keyword
-   :onyx/type :output})
+   :onyx/type (s/enum :output)})
 
 (def partial-fn-task
   {:onyx/fn NamespacedKeyword})


(def Window
  {:window/id s/Keyword
   :window/task s/Keyword
   :window/type WindowType
   :window/window-key s/Any
   :window/aggregation (s/either s/Keyword [s/Keyword])

(def partial-input-task
  {:onyx/plugin NamespacedKeyword
   :onyx/medium s/Keyword
   :onyx/type (s/enum :input)
   (s/optional-key :onyx/input-retry-timeout) PosInt 
   (s/optional-key :onyx/pending-timeout) PosInt 
   (s/optional-key :onyx/max-pending) PosInt})
