Stream after-hook processing in WellTransferer

[jirhiker]

Summary

• process after-hook wells in streamed batches using yield_per instead of materializing all wells
• reuse a shared chunk handler to reduce repeated setup and logging overhead

Testing

• not run (not requested)

---

Codex Task

[chatgpt-codex-connector]

💡 Codex Review

Here are some automated review suggestions for this pull request.

ℹ️ About Codex in GitHub

Your team has set up Codex to review pull requests in this repo. Reviews are triggered when you

• Open a pull request for review
• Mark a draft as ready
• Comment "@codex review".

If Codex has suggestions, it will comment; otherwise it will react with 👍.

Codex can also answer questions or update the PR. Try commenting "@codex address that feedback".

[chatgpt-codex-connector]

Avoid committing while streaming yield_per results

The new for well in query.yield_per(chunk_size) loop keeps the SELECT cursor open while _process_chunk commits the session. On PostgreSQL and other backends, committing a transaction closes the streaming cursor, so once more than chunk_size wells exist the next fetch will raise or silently stop and only the first batch will be processed. The previous list-based approach materialized all wells before each commit and did not hit this cursor-closing behavior. Consider deferring the commit until after iteration or reading wells in a separate session/connection that is not committed mid-stream.

Useful? React with 👍 / 👎.