         projectors (cond-> [] (not no-projectors) (conj (config/projectors persistence projection))
                            (not no-timeline) (conj (config/timeline persistence)))
         processor (processor/create persistence projectors)]
-    (doseq [json-file json-files]
-      (log/info "Processing " json-file)
-      (with-open [s (clojure.java.io/reader json-file)]
-        (dorun (consume processor (features-from-stream s :dataset dataset-name)))))
+    (dorun (consume processor (features-from-files json-files :dataset dataset-name)))
     (do (log/info "Shutting down.")
         (shutdown processor)))
   (log/info "done")


(defn add-templates-and-create-extract [template-location dataset collection extract-type extract-version]
  (let [templates-with-metadata (template/templates-with-metadata dataset template-location)]
    (do 
      (doseq [t templates-with-metadata] 
        (template/add-or-update-template t))
      (extracts/fill-extract dataset collection extract-type (read-string extract-version)))))
 
;(with-open [s (file-stream ".test-files/new-features-single-collection-100000.json")] (time (last (features-from-package-stream s))))

            [clojure.tools.logging :as log])
  (:gen-class))

(declare cli-options features-from-files)

(defn execute [{:keys [json-files
                       dataset-name
