(opendal) branch main updated: feat(bindings/c): enable RetryLayer by default (#6031)

[xuanwo]

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

xuanwo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/opendal.git


The following commit(s) were added to refs/heads/main by this push:
     new 2d130b603 feat(bindings/c): enable RetryLayer by default (#6031)
2d130b603 is described below

commit 2d130b603a9229890c390f4063f957c3e5b29cd8
Author: Hanchin Hsieh <m...@yuchanns.xyz>
AuthorDate: Wed Apr 16 10:52:17 2025 +0800

    feat(bindings/c): enable RetryLayer by default (#6031)
    
    ci(bindings/go): affected by c
---
 .github/scripts/test_behavior/plan.py | 5 +++++
 bindings/c/src/operator.rs            | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/.github/scripts/test_behavior/plan.py 
b/.github/scripts/test_behavior/plan.py
index cb873d93a..8f3247327 100755
--- a/.github/scripts/test_behavior/plan.py
+++ b/.github/scripts/test_behavior/plan.py
@@ -158,6 +158,11 @@ def calculate_hint(changed_files: list[str]) -> Hint:
                 setattr(hint, f"binding_{language}", True)
                 hint.all_service = True
 
+        # c affected
+        if p.startswith("bindings/c/"):
+            hint.binding_go = True
+            hint.all_service = True
+
         # bin affected
         for bin in BIN:
             if p.startswith(f"bin/{bin}"):
diff --git a/bindings/c/src/operator.rs b/bindings/c/src/operator.rs
index 84751fc49..48ab4a707 100644
--- a/bindings/c/src/operator.rs
+++ b/bindings/c/src/operator.rs
@@ -87,7 +87,7 @@ fn build_operator(
     schema: core::Scheme,
     map: HashMap<String, String>,
 ) -> core::Result<core::Operator> {
-    let mut op = core::Operator::via_iter(schema, map)?;
+    let mut op = core::Operator::via_iter(schema, 
map)?.layer(core::layers::RetryLayer::new());
     if !op.info().full_capability().blocking {
         let runtime =
             tokio::runtime::Handle::try_current().unwrap_or_else(|_| 
RUNTIME.handle().clone());