style(acms): fix ruff format violations in hot storage tier
CI / push-validation (pull_request) Successful in 27s
CI / helm (pull_request) Successful in 58s
CI / lint (pull_request) Successful in 3m50s
CI / quality (pull_request) Successful in 4m6s
CI / typecheck (pull_request) Successful in 4m35s
CI / security (pull_request) Successful in 4m31s
CI / unit_tests (pull_request) Failing after 4m26s
CI / docker (pull_request) Has been skipped
CI / build (pull_request) Successful in 3m38s
CI / e2e_tests (pull_request) Successful in 6m58s
CI / integration_tests (pull_request) Successful in 7m51s
CI / coverage (pull_request) Successful in 13m45s
CI / status-check (pull_request) Failing after 3s

Apply ruff format to hot.py and acms_hot_storage_tier_steps.py to fix
CI lint job failure (format --check was rejecting multi-line expressions
that ruff prefers on a single line).

ISSUES CLOSED: #9972
This commit is contained in:
2026-04-22 22:48:11 +00:00
parent 7a599a29eb
commit d5431c0aa6
2 changed files with 5 additions and 15 deletions
@@ -285,9 +285,7 @@ def step_when_concurrent_puts(
except Exception as exc:
context.concurrent_exception = exc
threads = [
threading.Thread(target=worker, args=(i,)) for i in range(num_threads)
]
threads = [threading.Thread(target=worker, args=(i,)) for i in range(num_threads)]
for t in threads:
t.start()
for t in threads:
@@ -327,9 +325,7 @@ def step_when_concurrent_puts_and_gets(
threads = [
threading.Thread(target=putter, args=(i,)) for i in range(num_threads)
] + [
threading.Thread(target=getter, args=(i,)) for i in range(num_threads2)
]
] + [threading.Thread(target=getter, args=(i,)) for i in range(num_threads2)]
for t in threads:
t.start()
for t in threads:
@@ -351,9 +347,7 @@ def step_when_concurrent_large_puts(context: Any, num_threads: int) -> None:
except Exception as exc:
context.concurrent_exception = exc
threads = [
threading.Thread(target=worker, args=(i,)) for i in range(num_threads)
]
threads = [threading.Thread(target=worker, args=(i,)) for i in range(num_threads)]
for t in threads:
t.start()
for t in threads:
+2 -6
View File
@@ -60,13 +60,9 @@ class HotStorageTier:
on_evict: Callable[[str, str], None] | None = None,
) -> None:
if max_entries is not None and max_entries < 1:
raise ValueError(
f"max_entries must be at least 1, got {max_entries}"
)
raise ValueError(f"max_entries must be at least 1, got {max_entries}")
if max_bytes is not None and max_bytes < 1:
raise ValueError(
f"max_bytes must be at least 1, got {max_bytes}"
)
raise ValueError(f"max_bytes must be at least 1, got {max_bytes}")
self._max_entries = max_entries
self._max_bytes = max_bytes