You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@opendal.apache.org by xu...@apache.org on 2026/10/26 18:28:26 UTC

(opendal-yinyang) branch xuanwo/managed-sync-regressions updated: fix: keep delayed receipt run within a join future

This is an automated email from the ASF dual-hosted git repository.

Xuanwo pushed a commit to branch xuanwo/managed-sync-regressions
in repository https://gitbox.apache.org/repos/asf/opendal-yinyang.git


The following commit(s) were added to refs/heads/xuanwo/managed-sync-regressions by this push:
     new 590652e  fix: keep delayed receipt run within a join future
590652e is described below

commit 590652eaa1a168ecb266066981d1871bc6d01793
Author: Xuanwo <gi...@xuanwo.io>
AuthorDate: Tue Oct 27 02:28:20 2026 +0800

    fix: keep delayed receipt run within a join future
---
 tests/directory_sync.rs | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/tests/directory_sync.rs b/tests/directory_sync.rs
index 3aa5f8e..d6bb41c 100644
--- a/tests/directory_sync.rs
+++ b/tests/directory_sync.rs
@@ -418,10 +418,9 @@ async fn local_edit_during_delayed_publication_receipt_stays_pending() {
         std::fs::write(&file, b"version two").expect("local v2 write");
         release.notify_one();
     };
-    let outcome1 = tokio::time::timeout(
-        std::time::Duration::from_secs(60),
-        tokio::join!(run1, writer),
-    )
+    let outcome1 = tokio::time::timeout(std::time::Duration::from_secs(60), async {
+        tokio::join!(run1, writer)
+    })
     .await
     .expect("v1 publication must commit and release its receipt in time")
     .0