UniqAI/open-webui
1
0
Fork 0
mirror of https://github.com/open-webui/open-webui synced 2024-11-25 21:38:43 +00:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Timothy J. Baek 2024-10-20 23:48:28 -07:00
parent e43e91edd3
commit cd8271eb95
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
backend/open_webui/storage/provider.py
View File

@ -19,7 +19,6 @@ from open_webui.config import (
import boto3 import boto3
from boto3.s3 import S3Client
from botocore.exceptions import ClientError from botocore.exceptions import ClientError
from typing import BinaryIO, Tuple, Optional from typing import BinaryIO, Tuple, Optional
@ -96,7 +95,7 @@ class StorageProvider:
if os.path.isfile(file_path): if os.path.isfile(file_path):
os.remove(file_path) os.remove(file_path)
else: else:
raise FileNotFoundError(f"File {filename} not found in local storage.") print(f"File {file_path} not found in local storage.")
def _delete_all_from_s3(self) -> None: def _delete_all_from_s3(self) -> None:
"""Handles deletion of all files from S3 storage.""" """Handles deletion of all files from S3 storage."""
@ -126,9 +125,7 @@ class StorageProvider:
except Exception as e: except Exception as e:
print(f"Failed to delete {file_path}. Reason: {e}") print(f"Failed to delete {file_path}. Reason: {e}")
else: else:
raise FileNotFoundError( print(f"Directory {UPLOAD_DIR} not found in local storage.")
f"Directory {UPLOAD_DIR} not found in local storage."
)
def upload_file(self, file: BinaryIO, filename: str) -> Tuple[bytes, str]: def upload_file(self, file: BinaryIO, filename: str) -> Tuple[bytes, str]:
"""Uploads a file either to S3 or the local file system.""" """Uploads a file either to S3 or the local file system."""
@ -150,14 +147,16 @@ class StorageProvider:
"""Deletes a file either from S3 or the local file system.""" """Deletes a file either from S3 or the local file system."""
if self.storage_provider == "s3": if self.storage_provider == "s3":
self._delete_from_s3(filename) self._delete_from_s3(filename)
else:
# Always delete from local storage
self._delete_from_local(filename) self._delete_from_local(filename)
def delete_all_files(self) -> None: def delete_all_files(self) -> None:
"""Deletes all files from the storage.""" """Deletes all files from the storage."""
if self.storage_provider == "s3": if self.storage_provider == "s3":
self._delete_all_from_s3() self._delete_all_from_s3()
else:
# Always delete from local storage
self._delete_all_from_local() self._delete_all_from_local()