Merge remote-tracking branch 'origin/kanzhen/list_executor' into kanz…

…hen/new_fs_source
risingwavelabs · Sep 26, 2023 · f6e57e7 · f6e57e7
2 parents e07bc0d + 2a7a6e1
commit f6e57e7
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/connector/src/source/filesystem/s3_v2/lister.rs b/src/connector/src/source/filesystem/s3_v2/lister.rs
@@ -71,9 +71,9 @@ pub struct S3SourceLister {
 impl S3SourceLister {
     #[try_stream(boxed, ok = Vec<FsPage>, error = RwError)]
     async fn paginate_inner(self) {
-        loop { // start a new round
+        'round: loop { // start a new round
             let mut next_continuation_token = None;
-            loop { // loop to paginate
+            'truncated: loop { // loop to paginate
                 let mut req = self
                     .client
                     .list_objects_v2()
@@ -113,7 +113,7 @@ impl S3SourceLister {
                 if res.is_truncated() {
                     next_continuation_token = Some(res.next_continuation_token.unwrap())
                 } else {
-                    break;
+                    break 'truncated;
                 }
             }
         }