                 :onyx/type
                 :onyx/batch-size]
           :opt [:onyx/batch-timeout
+                :onyx/batch-fn?
                 :onyx/fn
                 :onyx/uniqueness-key
                 :onyx/deduplicate?
                 :onyx/group-by-key
                 :onyx/group-by-fn
+                :onyx/flux-policy
                 :onyx/n-peers
                 :onyx/min-peers
                 :onyx/max-peers

                :onyx/max-peers
                :onyx/group-by-key
                :onyx/group-by-fn
                :onyx/params
                :onyx/required-tags
                :onyx/plugin

                :onyx/type
                :onyx/batch-size]
          :opt [:onyx/batch-timeout
                :onyx/batch-fn?
                :onyx/fn
                :onyx/uniqueness-key
                :onyx/deduplicate?
