           pool (cp/threadpool jobs)
           mstore (create-mstore cass-host options)
           pstore (create-pstore es-url options)
-          process-fn (fn [file]
-                       (wlog/info "Processing path: " file)
-                       (when-not @wlog/print-log?
-                         (prog/tick))
-                       (process-file file root-dir mstore pstore tenant from to
-                                     options))]
+          process-file-fn (fn [file]
+                            (wlog/info "Processing path: " file)
+                            (when-not @wlog/print-log?
+                              (prog/tick))
+                            (process-file file root-dir mstore pstore tenant
+                                          from to options path-fn points-fn))]
       (try
         (prog/set-progress-bar!
          "[:bar] :percent :done/:total Elapsed :elapseds ETA :etas")


(defn- process
  "Process a Whisper database."
  [source tenant cass-host es-url options start-title title]
  (wlog/set-logging! options)
  (try
    (wlog/info start-title)

        (when-not @wlog/print-log?
          (println title)
          (prog/init files-count))
        (dorun (cp/pmap pool process-file-fn files))
        (when-not @wlog/print-log?
          (prog/done))
        (catch Exception e
