   [catalog]
   (doseq [entry catalog]
     (schema/validate catalog-entry-validator entry)
+    (schema/validate group-entry-validator)
     (name-and-type-not-equal entry)))
 
 (defn validate-workflow-names [{:keys [workflow catalog]}]

                      :else
                      (merge base-catalog-entry-validator {:onyx/fn schema/Keyword})))

(defn task-dispatch-validator [task]
  (when (= (:onyx/name task)
           (:onyx/type task))

   :onyx/batch-size (schema/pred pos? 'pos?)
   schema/Keyword schema/Any})

(def group-validator
  {:onyx/min-peers schema/Int
   :onyx/flux-policy (schema/enum :continue :kill)})

(defn edge-two-nodes? [edge]
  (= (count edge) 2))

