Quick follow-up on #7458 — the key invariant in the prototype is that each InputId still has exactly one writer, while concurrency is bounded across different inputs rather than within one input. If that matches the intended semantics for BlockingSink, I can clean this up and open a PR.

changes = daft.read_iceberg_changes( table, start_snapshot_id=100, # exclusive end_snapshot_id=200, # inclusive )

Hi, was this intended for #7458? I think this might be for another thread.

FYI banned the above user for spam and posting of potentially malicious binaries