diff --git a/src/datachain/lib/arrow.py b/src/datachain/lib/arrow.py
index 28954477b..2c3aebb2f 100644
--- a/src/datachain/lib/arrow.py
+++ b/src/datachain/lib/arrow.py
@@ -33,7 +33,7 @@ def _open(self, path, mode="rb", *args, **kwargs):
         # reads the whole file in-memory.
         (uri,) = self.references[path]
         protocol, _ = split_protocol(uri)
-        return self.fss[protocol]._open(uri, mode, *args, **kwargs)
+        return self.fss[protocol].open(uri, mode, *args, **kwargs)
 
 
 class ArrowGenerator(Generator):