You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository was archived by the owner on Jan 6, 2023. It is now read-only.
fails validation when submitting a job. This is printed in the REPL:
------ Onyx Job Error -----
There was a validation error in your catalog for key 9
{:onyx/name:example/compute-average:onyx/fn:clojure.core/identity:onyx/type:function:onyx/batch-size5:onyx/batch-timeout50:onyx/group-by-fn:nexample/some-grouping-fn:onyx/flux-policy:kill }
------
The true reason it failed is revealed when validating by hand:
(require '[onyx.schema :refer [Job]])
(require '[schema.core :as schema])
(schema/validate Job job-map)
clojure.lang.ExceptionInfo: Value does not match schema: {:catalog [nilnilnilnilnilnilnilnilnil (not (valid-flux-policy-min-max-n-peers a-clojure.lang.PersistentArrayMap)) nil]}
So for this particular misconfiguration, the validation error is getting swallowed somewhere.