Revert "Set timeout for the first request"

This reverts commit 5704fbf.

Author: deuszx

linera-core/src/client/requests_scheduler/mod.rs

@@ -21,7 +21,7 @@ pub const CACHE_TTL_MS: u64 = 2000;
 pub const CACHE_MAX_SIZE: usize = 1000;
 pub const MAX_REQUEST_TTL_MS: u64 = 200;
 pub const ALPHA_SMOOTHING_FACTOR: f64 = 0.1;
-pub const STAGGERED_DELAY_MS: u64 = 150;
+pub const STAGGERED_DELAY_MS: u64 = 75;
 
 /// Configuration for the `RequestsScheduler`.
 #[derive(Debug, Clone)]

linera-core/src/client/requests_scheduler/scheduler.rs

@@ -4,10 +4,7 @@
 use std::{cmp::Ordering, collections::BTreeMap, future::Future, sync::Arc};
 
 use custom_debug_derive::Debug;
-use futures::{
-    stream::{FuturesUnordered, StreamExt},
-    FutureExt,
-};
+use futures::stream::{FuturesUnordered, StreamExt};
 use linera_base::{
     crypto::ValidatorPublicKey,
     data_types::{Blob, BlobContent, BlockHeight},
@@ -666,15 +663,7 @@ impl<Env: Environment> RequestsScheduler<Env> {
 
         // Execute the actual request
         tracing::trace!(key = ?key, peer = ?peer, "executing new request");
-        let result = futures::select! {
-            _timeout = linera_base::time::timer::sleep(self.retry_delay).fuse() => {
-                tracing::trace!(key = ?key, "retry delay elapsed, proceeding with request");
-                Err(NodeError::WorkerError { error: "timeout".to_string() }) // Placeholder error to trigger retries
-            },
-            result = operation(peer.clone()).fuse() => {
-                result
-            }
-        };
+        let result = operation(peer.clone()).await;
 
         // If the first request failed, try alternative peers in staggered parallel
         let result = if result.is_err() {
@@ -765,8 +754,7 @@ impl<Env: Environment> RequestsScheduler<Env> {
         }
 
         // Wait for first success or collect all failures
-        // Placeholder for the last error. If we error, this will be updated.
-        let mut last_error = NodeError::UnexpectedMessage;
+        let mut last_error = None;
 
         while let Some((peer_idx, result)) = futures.next().await {
             match result {
@@ -785,7 +773,7 @@ impl<Env: Environment> RequestsScheduler<Env> {
                         error = %e,
                         "staggered parallel retry attempt failed"
                     );
-                    last_error = e;
+                    last_error = Some(e);
                 }
             }
         }
@@ -795,7 +783,7 @@ impl<Env: Environment> RequestsScheduler<Env> {
             key = ?key,
             "all staggered parallel retry attempts failed"
         );
-        Err(last_error)
+        Err(last_error.unwrap_or(NodeError::UnexpectedMessage))
     }
 
     /// Returns all peers ordered by their score (highest first).