diff --git a/core/tests/behavior/list.rs b/core/tests/behavior/list.rs
index 492b3c7caf5d..65ac1b013b2e 100644
--- a/core/tests/behavior/list.rs
+++ b/core/tests/behavior/list.rs
@@ -183,18 +183,9 @@ pub async fn test_list_rich_dir(op: Operator) -> Result<()> {
         .map(|num| format!("test_list_rich_dir/file-{num}"))
         .collect();
 
-    expected
-        .iter()
-        .map(|v| async {
-            op.write(v, "test_list_rich_dir")
-                .await
-                .expect("create must succeed");
-        })
-        // Collect into a FuturesUnordered.
-        .collect::<FuturesUnordered<_>>()
-        // Collect to consume all features.
-        .collect::<Vec<_>>()
-        .await;
+    for path in expected.iter() {
+        op.write(path, "test_list_rich_dir").await?;
+    }
 
     let mut objects = op.with_limit(10).lister("test_list_rich_dir/").await?;
     let mut actual = vec![];
diff --git a/core/tests/behavior/utils.rs b/core/tests/behavior/utils.rs
index b5bd0970d871..c9c9a24e39f8 100644
--- a/core/tests/behavior/utils.rs
+++ b/core/tests/behavior/utils.rs
@@ -85,7 +85,7 @@ pub fn init_service<B: Builder>() -> Option<Operator> {
     let mut op = op
         .layer(LoggingLayer::default().with_backtrace_output(true))
         .layer(TimeoutLayer::new())
-        .layer(RetryLayer::new())
+        .layer(RetryLayer::new().with_max_times(4))
         .finish();
 
     if !op.info().full_capability().blocking {