Skip to content

Commit c16bf33

Browse files
fix(forester): drop 3s safe_deadline and repin photon to pushed commit
The new safe_deadline = timeout_deadline - 3s check caused every chunk future to bail immediately, since scheduled_v1_batch_timeout returns at most 2s. V1_BATCH_TIMEOUT_BUFFER already reserves headroom, so the extra subtraction was redundant. Repin external/photon from 8a0bbce (local-only) to a52fd36, which is reachable on origin/sergey/get-leaf-indices-api so CI can fetch it. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
1 parent 2d607a9 commit c16bf33

2 files changed

Lines changed: 3 additions & 6 deletions

File tree

forester/src/processor/v1/send_transaction.rs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -192,10 +192,7 @@ pub async fn send_batched_transactions<T: TransactionBuilder + Send + Sync + 'st
192192
let confirmation_poll_interval = config.confirmation_poll_interval;
193193

194194
async move {
195-
// Safety margin: stop 3s before deadline to avoid sending txs
196-
// that land after our light slot ends (ForesterNotEligible).
197-
let safe_deadline = timeout_deadline - std::time::Duration::from_secs(3);
198-
if cancel_signal.load(Ordering::SeqCst) || Instant::now() >= safe_deadline {
195+
if cancel_signal.load(Ordering::SeqCst) || Instant::now() >= timeout_deadline {
199196
return Ok(());
200197
}
201198

@@ -228,7 +225,7 @@ pub async fn send_batched_transactions<T: TransactionBuilder + Send + Sync + 'st
228225
};
229226
trace!(tree = %tree_id, "Built {} transactions in {:?}", transactions_to_send.len(), build_start_time.elapsed());
230227

231-
if transactions_to_send.is_empty() || Instant::now() >= safe_deadline {
228+
if transactions_to_send.is_empty() || Instant::now() >= timeout_deadline {
232229
return Ok(());
233230
}
234231

0 commit comments

Comments
 (0)