           (let [ttl (- time (- (utils/now) retention))]
             (when (> ttl min-ttl)
               (when run
-                (when-not disable-metric-store
+                (when mstore
                   (mstore/insert mstore tenant rollup period path time
                                  value ttl))
                 (when-not @path-stored?
-                  (when-not disable-path-store
+                  (when pstore
                     (pstore/insert pstore tenant path))
                   (swap! path-stored? (fn [_] true)))))))))))
 

        to (if to to utils/epoch-future)
        jobs (:jobs options default-jobs)
        pool (cp/threadpool jobs)
        mstore (mstore/cassandra-metric-store cass-host options)
        pstore (pstore/elasticsearch-metric-store es-url options)
        disable-progress (:disable-progress options false)
        progress-fn (if disable-progress #(println %) (fn [_] (prog/tick)))
        migrate-fn (fn [file]

        series (:series data)
        path-stored? (atom false)
        run (:run options false)
        min-ttl (:min-ttl options default-min-ttl)]
    (doseq [point series]
      (let [time (first point)
            value (last point)]
