fix(tests): Create test files one by one instead of concurrently (apa…

…che#3132) * fix(tests): Allow retry more times to make gdrive happy Signed-off-by: Xuanwo <[email protected]> * Don't create file at the same time Signed-off-by: Xuanwo <[email protected]> * Fix test Signed-off-by: Xuanwo <[email protected]> --------- Signed-off-by: Xuanwo <[email protected]>
Young-Flash · Sep 19, 2023 · bfe43e3 · bfe43e3
1 parent c01781d
commit bfe43e3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 13 deletions.
diff --git 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
@@ -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 {