 
 (s/def :onyx/group-by-fn namespaced-keyword?)
 
-(s/def :onyx/input-retry-timeout pos-int?)
-
 (s/def :onyx/language #{:clojure :java})
 
 (s/def :onyx/max-peers pos-int?)

  (s/coll-of (s/multi-spec window-type :window/type)
             :kind vector?))

(s/def :trigger/window-id keyword?)

(s/def :trigger/on keyword?)

(s/def :trigger/sync keyword?)

(s/def :trigger/pred keyword?)

(s/def :trigger/fire-all-extents? boolean?)

(s/def :trigger/watermark-percentage number?)

(s/def :trigger/doc string?)

(s/def :trigger/refinement
  #{:onyx.refinements/accumulating

    :millisecond :milliseconds
    :element :elements})

(s/def :window/doc string?)

(s/def :window/session-key any?)

(s/def :window/task keyword?)

(s/def :window/id (s/or :keyword keyword? :uuid uuid?))

(s/def :window/task keyword?)

(s/def :window/init any?)

(s/def :window/min-value number?)

(s/def :window/type
  #{:fixed :sliding :global :session})
