Apache Airflow Provider for Edge3

3.5.0 verified Sat May 09 auth: no python

This provider package allows integration of Edge3 edge computing with Apache Airflow. It transfers files from/to remote edge nodes. Current version as of May 2026 is 3.5.0, released with Airflow 2.x compatibility. Release cadence follows Airflow provider releases.

pip install apache-airflow-providers-edge3

Common errors

error ModuleNotFoundError: No module named 'airflow.providers.edge3' ↓

cause Missing provider installation or incorrect Python environment.

fix

Run 'pip install apache-airflow-providers-edge3' and ensure the environment is active.

error AirflowException: The conn_id `edge3_default` isn't defined ↓

cause Connection not configured in Airflow UI or environment.

fix

Set up Edge3 connection via Airflow UI (Admin -> Connections) or environment variable AIRFLOW_CONN_EDGE3_DEFAULT.

Warnings

breaking In 3.0.0, operator classes were renamed: Edge3ToSFTPOperator became SFTPToEdge3Operator. Old imports break. ↓

fix Update import to 'from airflow.providers.edge3.transfers.sftp_to_edge3 import SFTPToEdge3Operator'.

gotcha The provider requires Airflow 2.1+. Using with older Airflow raises ModuleNotFoundError for internal packages. ↓

fix Ensure Airflow version >=2.1.0 is installed.

Imports

Edge3SFTPHook
```
from airflow.providers.edge3.hooks.edge3 import Edge3SFTPHook
```
Common mistake is trying to import from 'airflow.contrib' or 'airflow.hooks'.
Edge3SFTPOperator
```
from airflow.providers.edge3.transfers.sftp_to_edge3 import SFTPToEdge3Operator
```
Operator class renamed in 3.0.0 from 'Edge3ToSFTP' to 'SFTPToEdge3Operator'.

Quickstart

Minimal DAG transferring a file from SFTP to Edge3.

from datetime import datetime
from airflow import DAG
from airflow.providers.edge3.transfers.sftp_to_edge3 import SFTPToEdge3Operator

with DAG(dag_id='edge3_example', start_date=datetime(2026,1,1), schedule_interval=None, catchup=False) as dag:
    transfer = SFTPToEdge3Operator(
        task_id='transfer_file',
        source_path='/home/user/file.txt',
        destination_path='/data/file.txt',
        sftp_conn_id='sftp_default',
        edge3_conn_id='edge3_default',
    )