From d96e8f9cc0f44c6375c7fff9509a81e845d26633 Mon Sep 17 00:00:00 2001 From: KiriAky 107 Date: Wed, 9 Sep 2026 13:14:48 +0800 Subject: [PATCH] =?UTF-8?q?test(sync):=20=E5=AE=B9=E5=BF=8D=E6=AD=A3?= =?UTF-8?q?=E7=A1=AE=E6=80=A7=E7=94=A8=E4=BE=8B=E4=B8=AD=E7=9A=84=E8=BE=93?= =?UTF-8?q?=E5=85=A5=E8=BE=93=E5=87=BA=E5=81=9C=E9=A1=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- scripts/acceptance_cases/s05_sync_uploads.py | 6 +++--- scripts/acceptance_cases/sync_production_stack.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/scripts/acceptance_cases/s05_sync_uploads.py b/scripts/acceptance_cases/s05_sync_uploads.py index c29b8aa..f700e83 100644 --- a/scripts/acceptance_cases/s05_sync_uploads.py +++ b/scripts/acceptance_cases/s05_sync_uploads.py @@ -324,7 +324,7 @@ def main() -> int: "offset": len(data) } drop_complete_response(path + "/complete", auth["Authorization"]) - deadline = time.monotonic() + 10 + deadline = time.monotonic() + 120 while (stack.staging / upload_id).exists() and time.monotonic() < deadline: time.sleep(0.01) assert not (stack.staging / upload_id).exists() @@ -365,8 +365,8 @@ def main() -> int: with ThreadPoolExecutor(max_workers=2) as pool: complete_future = pool.submit(race_complete) cleanup_future = pool.submit(race_cleanup) - complete_result = complete_future.result(timeout=30) - cleanup_result, latency = cleanup_future.result(timeout=30) + complete_result = complete_future.result(timeout=120) + cleanup_result, latency = cleanup_future.result(timeout=120) cleanup_latencies.append(latency) if index % 2 == 0: assert complete_result[0] == 200 and cleanup_result["expired_uploads_removed"] == 0 diff --git a/scripts/acceptance_cases/sync_production_stack.py b/scripts/acceptance_cases/sync_production_stack.py index d91c9b5..4277e0e 100644 --- a/scripts/acceptance_cases/sync_production_stack.py +++ b/scripts/acceptance_cases/sync_production_stack.py @@ -33,7 +33,7 @@ def free_port() -> int: return listener.getsockname()[1] -def call(method: str, url: str, *, headers=None, body=None, timeout=30): +def call(method: str, url: str, *, headers=None, body=None, timeout=120): request_headers = dict(headers or {}) payload = body if isinstance(body, (dict, list)):