    :order order
    :offset offset
    :count qount
-   :group-count group-count})
+   :groupCount group-count})
 
 (defn apply-step
   [steps step]

(defn ingest-label-collections!
  [graph element all]
  (let [processed (map (if (= element "vertex") process-vertex process-edge) all)]
    (doseq [lines (partition-all 1000 processed)]
      (let [labels (group-by :label lines)]
        (doseq [[label messages] labels]
          (mongo/ensure-collection! graph element label)
          (pprint/pprint
           (mongo/bulk-insert! graph label messages)))))))

(defn ingest-batches!
  [graph element all]

        config (config/read-path path)
        graph (mongo/connect! (:mongo config))]
    ;; (ingest-incrementally graph (:input env))
    (ingest-labels-from-path! graph (:input env))
    (log/info "ingest complete")))

(def gods-graph
