From 796e4e06d88cb74dbbe7f6d3025a16b1bac2b5ff Mon Sep 17 00:00:00 2001 From: David Hall Date: Tue, 14 Jan 2025 22:21:35 -0800 Subject: [PATCH] more --- src/levanter/store/cache.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/levanter/store/cache.py b/src/levanter/store/cache.py index 7543d4408..a7c88baef 100644 --- a/src/levanter/store/cache.py +++ b/src/levanter/store/cache.py @@ -1237,7 +1237,7 @@ async def _copy_one_array(dest_array: JaggedArrayStore, source_array: JaggedArra source_offsets = source_array.offsets[1 : source_num_rows + 1][ts.d[:].translate_to[0]] source_offsets = _virtual_offset(source_offsets, data_offset) - delay = 1 + delay = 4 while True: try: async with ts.Transaction() as txn: @@ -1253,7 +1253,7 @@ async def _copy_one_array(dest_array: JaggedArrayStore, source_array: JaggedArra logger.info("Rate limit exceeded. Retrying.") await asyncio.sleep(delay) delay *= 2 - if delay > 60: + if delay > 120: raise futures.append(offset_future)