瀏覽代碼

[raz_adls] Check when setting abfs default_fs to start with `abfs://`

Harshg999 4 年之前
父節點
當前提交
5d506b76af
共有 1 個文件被更改,包括 1 次插入4 次删除
  1. 1 4
      desktop/libs/azure/src/azure/conf.py

+ 1 - 4
desktop/libs/azure/src/azure/conf.py

@@ -77,10 +77,7 @@ def get_default_abfs_url():
 def get_default_abfs_fs():
 def get_default_abfs_fs():
   default_fs = core_site.get_default_fs()
   default_fs = core_site.get_default_fs()
 
 
-  if default_fs:
-    return default_fs
-  else:
-    return ABFS_CLUSTERS['default'].FS_DEFAULTFS.get()
+  return default_fs if default_fs and default_fs.startwith('abfs://') else ABFS_CLUSTERS['default'].FS_DEFAULTFS.get()
 
 
 ADLS_CLUSTERS = UnspecifiedConfigSection(
 ADLS_CLUSTERS = UnspecifiedConfigSection(
   "adls_clusters",
   "adls_clusters",