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?