From 2dc71c67cf858b953bf92dd0417abe5e79310719 Mon Sep 17 00:00:00 2001 From: wassname <1103714+wassname@users.noreply.github.com> Date: Wed, 29 Jul 2026 11:26:41 +0800 Subject: [PATCH] Retry transient generation rate limits --- pipeline.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pipeline.py b/pipeline.py index 9650cfe..e226431 100644 --- a/pipeline.py +++ b/pipeline.py @@ -140,6 +140,7 @@ def openrouter_client(): return OpenAI( base_url="https://openrouter.ai/api/v1", api_key=os.environ["OPENROUTER_API_KEY"], + max_retries=10, ) @@ -270,7 +271,7 @@ def generate(): logger.info(f"GENERATE: {len(cached)} cached, {len(jobs)} calls") client = openrouter_client() errors = 0 - with ThreadPoolExecutor(max_workers=8) as executor: + with ThreadPoolExecutor(max_workers=4) as executor: futures = [executor.submit(generate_one, client, job) for job in jobs] for index, future in enumerate(as_completed(futures), 1): record = future.result()