   [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]}]

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

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


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

(def group-entry-validator
  (schema/conditional #(and (= (:onyx/type %) :function)
                            (or (not (nil? (:onyx/group-by-key %)))
                                (not (nil? (:onyx/group-by-fn %)))))
                      group-validator))

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