pengjunjie/ragflow
1
0
Fork 1
mirror of https://github.com/infiniflow/ragflow.git synced 2025-12-08 20:42:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix:RAGFlowOSS.put() got an unexpected keyword argument 'tenant_id' (#10712)

Browse Source 
### What problem does this PR solve?

https://github.com/infiniflow/ragflow/issues/10700

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
Stephen Hu
2025-10-22 09:30:41 +08:00
committed by GitHub
parent 2d491188b8
commit 307cdc62ea
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
rag/utils/oss_conn.py
View File

@ -106,7 +106,7 @@ class RAGFlowOSS:
@use_prefix_path @use_prefix_path
@use_default_bucket @use_default_bucket
def put(self, bucket, fnm, binary): def put(self, bucket, fnm, binary, tenant_id=None):
logging.debug(f"bucket name {bucket}; filename :{fnm}:") logging.debug(f"bucket name {bucket}; filename :{fnm}:")
for _ in range(1): for _ in range(1):
try: try:
@ -123,7 +123,7 @@ class RAGFlowOSS:
@use_prefix_path @use_prefix_path
@use_default_bucket @use_default_bucket
def rm(self, bucket, fnm): def rm(self, bucket, fnm, tenant_id=None):
try: try:
self.conn.delete_object(Bucket=bucket, Key=fnm) self.conn.delete_object(Bucket=bucket, Key=fnm)
except Exception: except Exception:
@ -131,7 +131,7 @@ class RAGFlowOSS:
@use_prefix_path @use_prefix_path
@use_default_bucket @use_default_bucket
def get(self, bucket, fnm): def get(self, bucket, fnm, tenant_id=None):
for _ in range(1): for _ in range(1):
try: try:
r = self.conn.get_object(Bucket=bucket, Key=fnm) r = self.conn.get_object(Bucket=bucket, Key=fnm)
@ -145,7 +145,7 @@ class RAGFlowOSS:
@use_prefix_path @use_prefix_path
@use_default_bucket @use_default_bucket
def obj_exist(self, bucket, fnm): def obj_exist(self, bucket, fnm, tenant_id=None):
try: try:
if self.conn.head_object(Bucket=bucket, Key=fnm): if self.conn.head_object(Bucket=bucket, Key=fnm):
return True return True
@ -157,7 +157,7 @@ class RAGFlowOSS:
@use_prefix_path @use_prefix_path
@use_default_bucket @use_default_bucket
def get_presigned_url(self, bucket, fnm, expires): def get_presigned_url(self, bucket, fnm, expires, tenant_id=None):
for _ in range(10): for _ in range(10):
try: try:
r = self.conn.generate_presigned_url('get_object', r = self.conn.generate_presigned_url('get_object',