From 848705a67dfa9b81910042155fc568072ffe9985 Mon Sep 17 00:00:00 2001 From: CI Bot Date: Fri, 24 Jul 2026 10:47:36 +0800 Subject: [PATCH] =?UTF-8?q?style:=20black=E6=A0=BC=E5=BC=8F=E5=8C=96storag?= =?UTF-8?q?e.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- packages/shared/storage.py | 16 ++++------------ 1 file changed, 4 insertions(+), 12 deletions(-) diff --git a/packages/shared/storage.py b/packages/shared/storage.py index fcf9997f0..500ae1f29 100755 --- a/packages/shared/storage.py +++ b/packages/shared/storage.py @@ -98,9 +98,7 @@ class SharedStorageService(StoragePort): def diagnose(self) -> None: """输出存储配置诊断日志。""" key_id_display = ( - f"{self.access_key_id[:4]}...{self.access_key_id[-4:]}" - if len(self.access_key_id) > 8 - else "(empty)" + f"{self.access_key_id[:4]}...{self.access_key_id[-4:]}" if len(self.access_key_id) > 8 else "(empty)" ) logger.info( "[OSS诊断] endpoint=%s bucket_name=%s access_key_id=%s", @@ -156,9 +154,7 @@ class SharedStorageService(StoragePort): try: if isinstance(file_or_path, (str, Path)): - self.bucket.put_object_from_file( - storage_key, str(file_or_path), headers={"Content-Type": content_type} - ) + self.bucket.put_object_from_file(storage_key, str(file_or_path), headers={"Content-Type": content_type}) else: file_or_path.seek(0) # type: ignore[attr-defined] self.bucket.put_object(storage_key, file_or_path, headers={"Content-Type": content_type}) @@ -282,9 +278,7 @@ class SharedStorageService(StoragePort): logger.error("OSS not configured, cannot download: %s", asset_storage_key[:80]) return False try: - self.bucket.get_object_to_file( - self._normalize_storage_key(asset_storage_key), str(local_path) - ) + self.bucket.get_object_to_file(self._normalize_storage_key(asset_storage_key), str(local_path)) return local_path.exists() and local_path.stat().st_size > 0 except Exception: logger.exception("下载素材失败: %s", asset_storage_key) @@ -375,9 +369,7 @@ class SharedStorageService(StoragePort): ], ], } - encoded_policy = base64.b64encode( - json.dumps(policy, separators=(",", ":")).encode("utf-8") - ).decode("ascii") + encoded_policy = base64.b64encode(json.dumps(policy, separators=(",", ":")).encode("utf-8")).decode("ascii") signature = base64.b64encode( hmac.new( self.access_key_secret.encode("utf-8"),