                 :onyx.core/emitted-exhausted?
                 :onyx.core/metadata
                 :onyx.core/serialized-task
+                :onyx.core/task-map
                 :onyx.core/workflow
+                :onyx.core/catalog
                 :onyx.core/flow-conditions
                 :onyx.core/windows
                 :onyx.core/triggers

(s/def :onyx.core/serialized-task any?)

(s/def :onyx.core/workflow (s/get-spec :job/workflow))

(s/def :onyx.core/flow-conditions
  (s/get-spec :job/flow-conditions))

                :onyx.core/windows-state
                :onyx.core/filter-state
                :onyx.core/batch]))
