From afdb61326e14d191d72747d184d241e62b8b4da8 Mon Sep 17 00:00:00 2001
From: Eitan Seri-Levi <eserilev@ucsc.edu>
Date: Thu, 30 Apr 2026 15:36:06 +0200
Subject: [PATCH] inclusion_list_due_bps

---
 .../validator_services/src/inclusion_list_service.rs       | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/validator_client/validator_services/src/inclusion_list_service.rs b/validator_client/validator_services/src/inclusion_list_service.rs
index b57a2d4090..5cf9bd79f7 100644
--- a/validator_client/validator_services/src/inclusion_list_service.rs
+++ b/validator_client/validator_services/src/inclusion_list_service.rs
@@ -150,11 +150,14 @@ impl<S: ValidatorStore + 'static, T: SlotClock + 'static> InclusionListService<S
 
         let executor = self.executor.clone();
         let chain_spec = spec.clone();
+        let il_due_fraction = spec.inclusion_list_due_bps as u32;
         let interval_fut = async move {
             loop {
                 if let Some(duration_to_next_slot) = self.slot_clock.duration_to_next_slot() {
-                    // 3/4 of the way into the slot
-                    sleep(duration_to_next_slot + (slot_duration * 3 / 4)).await;
+                    // Wait until the start of the next slot, then sleep to
+                    // inclusion_list_due_bps fraction into that slot.
+                    let il_offset = slot_duration * il_due_fraction / 10000;
+                    sleep(duration_to_next_slot + il_offset).await;
                     if let Err(e) = self.spawn_inclusion_list_task(slot_duration, &chain_spec) {
                         crit!(
                             error = ?e,