[incubator-opendal] branch main updated: chore(operator): apply max_batch_limit for async operator (#1641)

[xu...@apache.org]

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/incubator-opendal.git


The following commit(s) were added to refs/heads/main by this push:
     new dfb8d1c8 chore(operator): apply max_batch_limit for async operator (#1641)
dfb8d1c8 is described below

commit dfb8d1c8f9487db0372bd27a9f04a803ab792f8b
Author: ClSlaid <ca...@bupt.edu.cn>
AuthorDate: Thu Mar 16 17:47:31 2023 +0800

    chore(operator): apply max_batch_limit for async operator (#1641)
    
    Signed-off-by: ClSlaid <ca...@bupt.edu.cn>
    Co-authored-by: Xuanwo <gi...@xuanwo.io>
---
 src/types/operator/operator.rs | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/types/operator/operator.rs b/src/types/operator/operator.rs
index 0eaa453d..d114de8c 100644
--- a/src/types/operator/operator.rs
+++ b/src/types/operator/operator.rs
@@ -73,10 +73,8 @@ impl Operator {
     }
 
     pub(crate) fn from_inner(accessor: FusedAccessor) -> Self {
-        Self {
-            accessor,
-            limit: 1000,
-        }
+        let limit = accessor.info().max_batch_operations().unwrap_or(1000);
+        Self { accessor, limit }
     }
 
     pub(super) fn into_inner(self) -> FusedAccessor {