fix use of renamed _flow_ds_type (Netflix#779)

AAAWallet · Oct 21, 2021 · a22f96f · a22f96f
1 parent 1f30607
commit a22f96f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metaflow/client/filecache.py b/metaflow/client/filecache.py
@@ -77,7 +77,7 @@ def get_log_legacy(
 
         ds_cls = self._get_datastore_storage_impl(ds_type)
         ds_root = ds_cls.path_join(*ds_cls.path_split(location)[:-5])
-        cache_id = self._flow_ds_type(ds_type, ds_root, flow_name)
+        cache_id = self._flow_ds_id(ds_type, ds_root, flow_name)
 
         token = '%s.cached' % sha1(os.path.join(
             run_id, step_name, task_id, '%s_log' % logtype).\