(iceberg-go) branch main updated: fix(table): report cancellation when the scan iterator channel closes (#2035)

[atserakhau]

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

laskoviymishka pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-go.git


The following commit(s) were added to refs/heads/main by this push:
     new 85396eb34 fix(table): report cancellation when the scan iterator 
channel closes (#2035)
85396eb34 is described below

commit 85396eb3449670980f6118faae6f972af7ce7d4f
Author: Badal Prasad Singh <ba...@datazip.io>
AuthorDate: Wed Sep 23 00:47:33 2026 +0530

    fix(table): report cancellation when the scan iterator channel closes 
(#2035)
    
    minor
    
    Signed-off-by: badalprasadsingh <ba...@datazip.io>
---
 table/arrow_scanner.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/table/arrow_scanner.go b/table/arrow_scanner.go
index fb732caeb..129cda66b 100644
--- a/table/arrow_scanner.go
+++ b/table/arrow_scanner.go
@@ -2187,6 +2187,10 @@ func createIteratorWithCleanup(ctx context.Context, 
numWorkers uint, records <-c
                                return
                        case enum, ok := <-sequenced:
                                if !ok {
+                                       if err := context.Cause(ctx); err != 
nil {
+                                               yield(nil, err)
+                                       }
+
                                        return
                                }