style: black格式化storage.py

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