From 19394751343bc464ce41edbe7438050e43d42126 Mon Sep 17 00:00:00 2001 From: Ivan Schasny Date: Wed, 15 Jan 2025 14:01:41 +0000 Subject: [PATCH] Add chunking for storage logs --- core/lib/dal/src/storage_logs_dal.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/core/lib/dal/src/storage_logs_dal.rs b/core/lib/dal/src/storage_logs_dal.rs index 13986b5779bc..e98c3b7e74db 100644 --- a/core/lib/dal/src/storage_logs_dal.rs +++ b/core/lib/dal/src/storage_logs_dal.rs @@ -506,15 +506,15 @@ impl StorageLogsDal<'_, '_> { for chunk in hashed_keys.chunks(chunk_size) { let rows = sqlx::query!( r#" - SELECT - hashed_key, - l1_batch_number, - index - FROM - initial_writes - WHERE - hashed_key = ANY($1::bytea []) - "#, + SELECT + hashed_key, + l1_batch_number, + index + FROM + initial_writes + WHERE + hashed_key = ANY($1::bytea []) + "#, &chunk as &[&[u8]], ) .instrument("get_l1_batches_and_indices_for_initial_writes")