airflow.providers.sftp.pools.sftp¶

Classes¶

SFTPClientPool

Lazy Thread-safe and Async-safe Singleton SFTP pool that keeps SSH and SFTP clients alive until exit, and limits concurrent usage to pool_size.

Module Contents¶

class airflow.providers.sftp.pools.sftp.SFTPClientPool(sftp_conn_id, pool_size=None)[source]¶

Bases: airflow.utils.log.logging_mixin.LoggingMixin

Lazy Thread-safe and Async-safe Singleton SFTP pool that keeps SSH and SFTP clients alive until exit, and limits concurrent usage to pool_size.

async acquire()[source]¶

async release(pair)[source]¶

async get_sftp_client()[source]¶

async close()[source]¶: Gracefully shutdown all connections in the pool for the current event loop.

async __aenter__()[source]¶

async __aexit__(exc_type, exc, tb)[source]¶

Was this entry helpful?