 (defn migrate
   "Do the migration."
   [source tenant cass-host es-url options]
-  (process source tenant cass-host es-url options migrate-path migrate-points
-           "Starting migration" "Migrating"))
+  (process source tenant cass-host es-url options migrator "Starting migration"
+           "Migrating"))
 
 (defn validate
   "Do the validation."
   [source tenant cass-host es-url options]
-  (process source tenant cass-host es-url options validate-path validate-points
-           "Starting validation" "Validating"))
+  (process source tenant cass-host es-url options validator "Starting validation"
+           "Validating"))
 
 (defn list-paths
   "List paths."

          (wlog/unhandled-error e))
        (finally
          (when mstore
            (deref-stats data-mstore-stats)
            (show-stats "Metric store stats" (deref-stats data-mstore-stats)
                        (mstore/get-stats mstore))
            (mstore/shutdown mstore))
          (when pstore
            (show-stats "Path store stats" (deref-stats data-pstore-stats)
                        (pstore/get-stats pstore))
            (pstore/shutdown pstore)))))
    (catch Exception e


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