From 50e93d15288d8f3daf0e66f8f9f034fffa5e919f Mon Sep 17 00:00:00 2001
From: Stephen Hu <812791840@qq.com>
Date: Mon, 27 Oct 2025 10:28:08 +0800
Subject: [PATCH] Fix: Opendal miss tenant id  (#10774)

### What problem does this PR solve?

as https://github.com/infiniflow/ragflow/pull/10712

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
---
 rag/utils/opendal_conn.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

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}")