sunildataengineer commented on PR #68298:
URL: https://github.com/apache/airflow/pull/68298#issuecomment-5142766664
Hi @dabla, @bugraoz93, and @potiuk
All requested changes from earlier reviews have been addressed and pushed to
this branch. Here is a summary of the updates:
Summary of Changes Addressed
Native Async I/O & Connection Reuse (@dabla):
Updated `SFTPHookAsync.transfer()` to use native async methods
(`retrieve_file`, `store_file`, `sftp.unlink`).
Refactored trigger class to `SFTPOperationTrigger` and delegated run
execution directly to `SFTPHookAsync.transfer()`.
Implemented single SSH connection reuse with `asyncio.Semaphore` and
`asyncio.gather()` for bounded concurrent transfers.
Enum Conversion & Branch Cleanup (@bugraoz93):
Converted `SFTPOperation` to an enum in
`providers/sftp/src/airflow/providers/sftp/hooks/sftp.py`.
Resolved merge conflict markers in `docs/index.rst` and `pyproject.toml`.
Updated dependency requirements (`asgiref`) and aligned newsfragment to
`68298.feature.rst`.
Branch State: Clean single-topic diff against latest `apache:main`, no merge
conflicts.
All review comments have been resolved inline. Could you please re-review
and approve the pending workflow runs when you have bandwidth? Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
