style: ruff format

Author: ServerSideHannes

s3proxy/concurrency.py

@@ -36,7 +36,7 @@ def _create_malloc_release() -> Callable[[], int] | None:
         libc.malloc_trim.argtypes = [ctypes.c_size_t]
         libc.malloc_trim.restype = ctypes.c_int
         return lambda: libc.malloc_trim(0)
-    except (OSError, AttributeError):
+    except OSError, AttributeError:
         return None
 
 

s3proxy/dashboard/collectors.py

@@ -134,7 +134,7 @@ def _latency_percentiles(cumulative: dict[str, float] | None = None) -> dict[str
             continue
         try:
             buckets.append((float(le), float(count)))
-        except (ValueError, TypeError):
+        except ValueError, TypeError:
             continue
     if total < 1 and buckets:
         total = max(c for _, c in buckets)

s3proxy/dashboard/stats_store.py

@@ -561,7 +561,7 @@ async def series(self, metric: str, range_key: str) -> tuple[list[float], list[f
         for k, v in raw.items():
             try:
                 points.append((int(k), float(v)))
-            except (ValueError, TypeError):
+            except ValueError, TypeError:
                 continue
         return bucket_series(points, window, bucket)
 
@@ -642,7 +642,7 @@ def _hfloat(h: dict, field: bytes) -> float:
         return 0.0
     try:
         return float(v)
-    except (ValueError, TypeError):
+    except ValueError, TypeError:
         return 0.0
 
 
@@ -652,7 +652,7 @@ def _decode_float_map(h: dict) -> dict[str, float]:
         key = k.decode() if isinstance(k, bytes) else str(k)
         try:
             out[key] = float(v)
-        except (ValueError, TypeError):
+        except ValueError, TypeError:
             continue
     return out
 
@@ -665,7 +665,7 @@ def _loads_sample(raw: bytes) -> RequestSample | None:
     try:
         d = orjson.loads(raw)
         return RequestSample(**d)
-    except (ValueError, TypeError):
+    except ValueError, TypeError:
         return None
 
 

s3proxy/request_handler.py

@@ -214,7 +214,7 @@ async def _handle_proxy_request_impl(
     dispatcher = RequestDispatcher(handler)
     try:
         return await dispatcher.dispatch(request, verified_creds)
-    except (HTTPException, S3Error):
+    except HTTPException, S3Error:
         raise
     except UnknownKidError as e:
         logger.warning("Cannot decrypt object: key not configured", kid=e.kid)

s3proxy/utils.py

@@ -17,7 +17,7 @@ def parse_http_date(date_str: str | None) -> datetime | None:
         return None
     try:
         return parsedate_to_datetime(date_str)
-    except (ValueError, TypeError):
+    except ValueError, TypeError:
         return None
 
 

tests/unit/test_list_objects_parallel.py

@@ -63,7 +63,7 @@ def test_parallel_order_and_fallback():
     contents = [
         _obj("a"),
         _obj(f"{INTERNAL_PREFIX}skip-me"),  # internal -> dropped
-        _obj("b", size=42),                  # HEAD fails -> fallback to listed size/etag
+        _obj("b", size=42),  # HEAD fails -> fallback to listed size/etag
         _obj("c"),
     ]