diff --git a/rag/utils/opendal_conn.py b/rag/utils/opendal_conn.py index 7642b33d4..1293516a9 100644 --- a/rag/utils/opendal_conn.py +++ b/rag/utils/opendal_conn.py @@ -65,20 +65,20 @@ class OpenDALStorage: r = self._operator.write(f"{bucket}/{fnm}", binary) return r - def put(self, bucket, fnm, binary): + def put(self, bucket, fnm, binary, tenant_id=None): self._operator.write(f"{bucket}/{fnm}", binary) - def get(self, bucket, fnm): + def get(self, bucket, fnm, tenant_id=None): return self._operator.read(f"{bucket}/{fnm}") - def rm(self, bucket, fnm): + def rm(self, bucket, fnm, tenant_id=None): self._operator.delete(f"{bucket}/{fnm}") self._operator.__init__() - def scan(self, bucket, fnm): + def scan(self, bucket, fnm, tenant_id=None): return self._operator.scan(f"{bucket}/{fnm}") - def obj_exist(self, bucket, fnm): + def obj_exist(self, bucket, fnm, tenant_id=None): return self._operator.exists(f"{bucket}/{fnm}")