Add root_url to DaskMSStore. Fixes incorrect stores for s3.

ratt-ru · Sep 14, 2023 · 4c7b856 · 4c7b856
1 parent f0c96f0
commit 4c7b856
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/daskms/experimental/fragments/__init__.py b/daskms/experimental/fragments/__init__.py
@@ -24,7 +24,7 @@ def get_ancestry(store, only_required=True):
         store = DaskMSStore(store)
 
     while True:
-        root_store = DaskMSStore(store.root)
+        root_store = DaskMSStore(store.root_url)
 
         if store.exists():
             try:

diff --git a/daskms/fsspec_store.py b/daskms/fsspec_store.py
@@ -94,6 +94,10 @@ def assert_type(self, store_type):
     def url(self):
         return f"{self.fs.unstrip_protocol(self.canonical_path)}"
 
+    @property
+    def root_url(self):
+        return f"{self.fs.unstrip_protocol(self.root)}"
+
     def subdirectories(self):
         return [
             d["name"]