From 3d4422630022de2d0b3b1108fb499a25d8fb8f20 Mon Sep 17 00:00:00 2001 From: Vrutik-0 <238077214+Vrutik-0@users.noreply.github.com> Date: Fri, 12 Jun 2026 00:20:09 +0530 Subject: [PATCH 1/4] Fix Typo in EdgeExecutor Architecture diagram --- providers/edge3/docs/img/distributed_architecture.svg | 2 +- providers/edge3/docs/img/edge_package.svg | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/providers/edge3/docs/img/distributed_architecture.svg b/providers/edge3/docs/img/distributed_architecture.svg index 1bbb56c6fce41..7acb5a38ff5f2 100644 --- a/providers/edge3/docs/img/distributed_architecture.svg +++ b/providers/edge3/docs/img/distributed_architecture.svg @@ -1,4 +1,4 @@ -
Cororate Networks
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Postgres DB
HTTPS
Firewall/
AppGW/
Ingress
Edge Worker
Proxy
Client
Client
Client
Airflow API-Server
Any Branch Legacy
Backend System
Distributed Airflow Architecture
Internet Based Client
Airflow Celery Worker (Pool)
Edge Worker
+
Corporate Networks
Corporate Networks
Remote Corporate Location
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Airflow Sch...
Postgres DB
Postgres DB
HTTPS
HTTPS
Firewall/
AppGW/
Ingress
Firewall/...
Edge Worker
Edge Worker
Proxy
Proxy
Client
Client
Client
Client
Client
Client
Airflow API-Server
Airflow A...
Any Branch Legacy
Backend System
Any Branch Lega...
Distributed Airflow Architecture
Distributed Airflow Architecture
Internet Based Client
Internet Based C...
Airflow Celery Worker (Pool)
Airflow Cel...
Edge Worker
Edge Worker
Text is not SVG - cannot display
\ No newline at end of file diff --git a/providers/edge3/docs/img/edge_package.svg b/providers/edge3/docs/img/edge_package.svg index 24408170c9cf5..6ac0698226447 100644 --- a/providers/edge3/docs/img/edge_package.svg +++ b/providers/edge3/docs/img/edge_package.svg @@ -1,4 +1,4 @@ -
Cororate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Client(s)
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
DB
Table: Edge Job
Task Instance Key
State
Queue
Command
(...)
Table: Worker Status
Hostname
Status
(...)
Airflow
Scheduler
Provider Package: Edge3
EdgeExecutor
Add / Report / Cleanup
Airflow
API-Server
Provider Package:
Edge3 Executor Plugin
View(s): Edge Worker - State, Job, Maintenance
Query
Query / Update
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
Update
Update
Edge
Worker
Provider Package: Edge3
CLI: `airflow edge worker ...`
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
Task Execution
via Task SDK
Table: Edge Logs
Task Instance Key
Timestamp
Log Text Chunk
Insert
Logs
DAG Sync
Internet Based Client(s)
HTTPS
Query
HTTPS
Proxy
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
+
Corporate Network(s) / Remote Location(s)
Corporate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
       Client(s)
...
Airflow Edge Worker Components / Provider Package
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
Airflo...
DB
DB
Table: Edge Job
Table: Edge Job
Task Instance Key
Task Instance Key
State
State
Queue
Queue
Command
Command
(...)
(...)
Table: Worker Status
Table: Worker Status
Hostname
Hostname
Status
Status
(...)
(...)
Airflow
Scheduler
Airflo...
Provider Package: Edge3
Provider Package: Edge3
EdgeExecutor
EdgeExecutor
Add / Report / Cleanup
Add / Report / Cleanup
Airflow
API-Server
Airf...
Provider Package:
Edge3 Executor Plugin
Provider Package:...
View(s): Edge Worker - State, Job, Maintenance
View(s): Edge Worker -...
Query
Query
Query / Update
Query / Update
HTTPS
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
REST API(s) Endpoints:...
Update
Update
Update
Update
Edge
Worker
Edge...
Provider Package: Edge3
CLI: `airflow edge worker ...`
Provider Package: Edge3...
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
- Poll & report job sta...
Task Execution
via Task SDK
Task Execution...
Table: Edge Logs
Table: Edge Logs
Task Instance Key
Task Instance Key
Timestamp
Timestamp
Log Text Chunk
Log Text Chunk
Insert
Insert
Logs
Logs
DAG Sync
DAG Sync
Internet Based Client(s)
Internet...
HTTPS
HTTPS
Query
Query
HTTPS
HTTPS
Proxy
Proxy
Task SDK API Endpoint
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
Firewal...
Text is not SVG - cannot display
\ No newline at end of file From 112a1b3e6c3f3f44efb0ca2d33161690c5450bcd Mon Sep 17 00:00:00 2001 From: Vrutik-0 <238077214+Vrutik-0@users.noreply.github.com> Date: Fri, 12 Jun 2026 00:50:04 +0530 Subject: [PATCH 2/4] Fix Typo in EdgeExecutor Architecture diagram1 --- providers/edge3/docs/img/distributed_architecture.svg | 2 +- providers/edge3/docs/img/edge_package.svg | 5 +---- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/providers/edge3/docs/img/distributed_architecture.svg b/providers/edge3/docs/img/distributed_architecture.svg index 7acb5a38ff5f2..ca803a73708b0 100644 --- a/providers/edge3/docs/img/distributed_architecture.svg +++ b/providers/edge3/docs/img/distributed_architecture.svg @@ -1,4 +1,4 @@ -
Corporate Networks
Corporate Networks
Remote Corporate Location
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Airflow Sch...
Postgres DB
Postgres DB
HTTPS
HTTPS
Firewall/
AppGW/
Ingress
Firewall/...
Edge Worker
Edge Worker
Proxy
Proxy
Client
Client
Client
Client
Client
Client
Airflow API-Server
Airflow A...
Any Branch Legacy
Backend System
Any Branch Lega...
Distributed Airflow Architecture
Distributed Airflow Architecture
Internet Based Client
Internet Based C...
Airflow Celery Worker (Pool)
Airflow Cel...
Edge Worker
Edge Worker
Text is not SVG - cannot display
\ No newline at end of file +
Cororate Networks
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Postgres DB
HTTPS
Firewall/
AppGW/
Ingress
Edge Worker
Proxy
Client
Client
Client
Airflow API-Server
Any Branch Legacy
Backend System
Distributed Airflow Architecture
Internet Based Client
Airflow Celery Worker (Pool)
Edge Worker
diff --git a/providers/edge3/docs/img/edge_package.svg b/providers/edge3/docs/img/edge_package.svg index 6ac0698226447..c75263d1bdd8a 100644 --- a/providers/edge3/docs/img/edge_package.svg +++ b/providers/edge3/docs/img/edge_package.svg @@ -1,4 +1 @@ - - - -
Corporate Network(s) / Remote Location(s)
Corporate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
       Client(s)
...
Airflow Edge Worker Components / Provider Package
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
Airflo...
DB
DB
Table: Edge Job
Table: Edge Job
Task Instance Key
Task Instance Key
State
State
Queue
Queue
Command
Command
(...)
(...)
Table: Worker Status
Table: Worker Status
Hostname
Hostname
Status
Status
(...)
(...)
Airflow
Scheduler
Airflo...
Provider Package: Edge3
Provider Package: Edge3
EdgeExecutor
EdgeExecutor
Add / Report / Cleanup
Add / Report / Cleanup
Airflow
API-Server
Airf...
Provider Package:
Edge3 Executor Plugin
Provider Package:...
View(s): Edge Worker - State, Job, Maintenance
View(s): Edge Worker -...
Query
Query
Query / Update
Query / Update
HTTPS
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
REST API(s) Endpoints:...
Update
Update
Update
Update
Edge
Worker
Edge...
Provider Package: Edge3
CLI: `airflow edge worker ...`
Provider Package: Edge3...
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
- Poll & report job sta...
Task Execution
via Task SDK
Task Execution...
Table: Edge Logs
Table: Edge Logs
Task Instance Key
Task Instance Key
Timestamp
Timestamp
Log Text Chunk
Log Text Chunk
Insert
Insert
Logs
Logs
DAG Sync
DAG Sync
Internet Based Client(s)
Internet...
HTTPS
HTTPS
Query
Query
HTTPS
HTTPS
Proxy
Proxy
Task SDK API Endpoint
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
Firewal...
Text is not SVG - cannot display
\ No newline at end of file +
Corporate Network(s) / Remote Location(s)
Corporate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
        Client(s)
...
Airflow Edge Worker Components / Provider Package
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
Airflo...
DB
DB
Table: Edge Job
Table: Edge Job
Task Instance Key
Task Instance Key
State
State
Queue
Queue
Command
Command
(...)
(...)
Table: Worker Status
Table: Worker Status
Hostname
Hostname
Status
Status
(...)
(...)
Airflow
Scheduler
Airflo...
Provider Package: Edge3
Provider Package: Edge3
EdgeExecutor
EdgeExecutor
Add / Report / Cleanup
Add / Report / Cleanup
Airflow
API-Server
Airf...
Provider Package:
Edge3 Executor Plugin
Provider Package:...
View(s): Edge Worker - State, Job, Maintenance
View(s): Edge Worker -...
Query
Query
Query / Update
Query / Update
HTTPS
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
REST API(s) Endpoints:...
Update
Update
Update
Update
Edge
Worker
Edge...
Provider Package: Edge3
CLI: `airflow edge worker ...`
Provider Package: Edge3...
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
- Poll & report job sta...
Task Execution
via Task SDK
Task Execution...
Table: Edge Logs
Table: Edge Logs
Task Instance Key
Task Instance Key
Timestamp
Timestamp
Log Text Chunk
Log Text Chunk
Insert
Insert
Logs
Logs
DAG Sync
DAG Sync
Internet Based Client(s)
Internet...
HTTPS
HTTPS
Query
Query
HTTPS
HTTPS
Proxy
Proxy
Task SDK API Endpoint
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
Firewal...
Text is not SVG - cannot display
\ No newline at end of file From f1bd3051800d2e98547504759544361041b97624 Mon Sep 17 00:00:00 2001 From: Vrutik-0 <238077214+Vrutik-0@users.noreply.github.com> Date: Fri, 12 Jun 2026 01:09:31 +0530 Subject: [PATCH 3/4] Fix Typo in EdgeExecutor Architecture diagrams --- providers/edge3/docs/img/distributed_architecture.svg | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/providers/edge3/docs/img/distributed_architecture.svg b/providers/edge3/docs/img/distributed_architecture.svg index ca803a73708b0..d75e9b385589c 100644 --- a/providers/edge3/docs/img/distributed_architecture.svg +++ b/providers/edge3/docs/img/distributed_architecture.svg @@ -1,4 +1 @@ - - - -
Cororate Networks
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Postgres DB
HTTPS
Firewall/
AppGW/
Ingress
Edge Worker
Proxy
Client
Client
Client
Airflow API-Server
Any Branch Legacy
Backend System
Distributed Airflow Architecture
Internet Based Client
Airflow Celery Worker (Pool)
Edge Worker
+
Corporate Networks
Corporate Networks
Remote Corporate Location
Remote Corporate Location
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
Kubernetes Cluster (optional)
Kubernetes Cluster (optional)
Airflow Scheduler
& DAG Parser
Airflow Sch...
Postgres DB
Postgres DB
HTTPS
HTTPS
Firewall/
AppGW/
Ingress
Firewall/...
Edge Worker
Edge Worker
Proxy
Proxy
Client
Client
Client
Client
Client
Client
Airflow API-Server
Airflow A...
Any Branch Legacy
Backend System
Any Branch Lega...
Distributed Airflow Architecture
Distributed Airflow Architecture
Internet Based Client
Internet Based Cl...
Airflow Celery Worker (Pool)
Airflow Cel...
Edge Worker
Edge Worker
Text is not SVG - cannot display
\ No newline at end of file From 502ee5e8f02e874d688d0fa1b15acc3685a0812f Mon Sep 17 00:00:00 2001 From: Vrutik-0 <238077214+Vrutik-0@users.noreply.github.com> Date: Fri, 12 Jun 2026 10:59:59 +0530 Subject: [PATCH 4/4] Fix Typo in EdgeExecutor Architecture diagrams --- providers/edge3/docs/img/edge_package.svg | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/providers/edge3/docs/img/edge_package.svg b/providers/edge3/docs/img/edge_package.svg index c75263d1bdd8a..38327bd72739d 100644 --- a/providers/edge3/docs/img/edge_package.svg +++ b/providers/edge3/docs/img/edge_package.svg @@ -1 +1 @@ -
Corporate Network(s) / Remote Location(s)
Corporate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem
        Client(s)
...
Airflow Edge Worker Components / Provider Package
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
Airflo...
DB
DB
Table: Edge Job
Table: Edge Job
Task Instance Key
Task Instance Key
State
State
Queue
Queue
Command
Command
(...)
(...)
Table: Worker Status
Table: Worker Status
Hostname
Hostname
Status
Status
(...)
(...)
Airflow
Scheduler
Airflo...
Provider Package: Edge3
Provider Package: Edge3
EdgeExecutor
EdgeExecutor
Add / Report / Cleanup
Add / Report / Cleanup
Airflow
API-Server
Airf...
Provider Package:
Edge3 Executor Plugin
Provider Package:...
View(s): Edge Worker - State, Job, Maintenance
View(s): Edge Worker -...
Query
Query
Query / Update
Query / Update
HTTPS
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
REST API(s) Endpoints:...
Update
Update
Update
Update
Edge
Worker
Edge...
Provider Package: Edge3
CLI: `airflow edge worker ...`
Provider Package: Edge3...
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
- Poll & report job sta...
Task Execution
via Task SDK
Task Execution...
Table: Edge Logs
Table: Edge Logs
Task Instance Key
Task Instance Key
Timestamp
Timestamp
Log Text Chunk
Log Text Chunk
Insert
Insert
Logs
Logs
DAG Sync
DAG Sync
Internet Based Client(s)
Internet...
HTTPS
HTTPS
Query
Query
HTTPS
HTTPS
Proxy
Proxy
Task SDK API Endpoint
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
Firewal...
Text is not SVG - cannot display
\ No newline at end of file +
Corporate Network(s) / Remote Location(s)
Corporate Network(s) / Remote Location(s)
Airflow Main Data Center or Cloud Deployment Ecosystem
Airflow Main Data Center or Cloud Deployment Ecosystem

Airflow Edge Worker Components / Provider Package
Airflow Edge Worker Components / Provider Package
Airflow Celery Worker
(Pool / Hybrid Execution)
Airflo...
DB
DB
Table: Edge Job
Table: Edge Job
Task Instance Key
Task Instance Key
State
State
Queue
Queue
Command
Command
(...)
(...)
Table: Worker Status
Table: Worker Status
Hostname
Hostname
Status
Status
(...)
(...)
Airflow
Scheduler
Airflo...
Provider Package: Edge3
Provider Package: Edge3
EdgeExecutor
EdgeExecutor
Add / Report / Cleanup
Add / Report / Cleanup
Airflow
API-Server
Airf...
Provider Package:
Edge3 Executor Plugin
Provider Package:...
View(s): Edge Worker - State, Job, Maintenance
View(s): Edge Worker -...
Query
Query
Query / Update
Query / Update
HTTPS
HTTPS
REST API(s) Endpoints:
- Fetch Job
- Report Result
- Heartbeat
- Log Upload (...)
REST API(s) Endpoints:...
Update
Update
Update
Update
Edge
Worker
Edge...
Provider Package: Edge3
CLI: `airflow edge worker ...`
Provider Package: Edge3...
- Poll & report job status
- Heartbeat, Maintenance
- Send log (chunks)
- Poll & report job sta...
Task Execution
via Task SDK
Task Execution...
Table: Edge Logs
Table: Edge Logs
Task Instance Key
Task Instance Key
Timestamp
Timestamp
Log Text Chunk
Log Text Chunk
Insert
Insert
Logs
Logs
DAG Sync
DAG Sync
Internet Based Client(s)
Internet...
HTTPS
HTTPS
Query
Query
HTTPS
HTTPS
Proxy
Proxy
Task SDK API Endpoint
Task SDK API Endpoint
Firewall/
AppGW/
Ingress
Firewal...
Client(s)
Client(s)
Text is not SVG - cannot display
\ No newline at end of file