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 NetworksRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Airflow Scheduler& DAG ParserPostgres DBHTTPSFirewall/AppGW/IngressEdge WorkerProxyClientClientClientAirflow API-ServerAny Branch LegacyBackend SystemDistributed Airflow ArchitectureInternet Based ClientAirflow Celery Worker (Pool)Edge Worker +Corporate NetworksCorporate NetworksRemote Corporate LocationRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Kubernetes Cluster (optional)Airflow Scheduler& DAG ParserAirflow Sch...Postgres DBPostgres DBHTTPSHTTPSFirewall/AppGW/IngressFirewall/...Edge WorkerEdge WorkerProxyProxyClientClientClientClientClientClientAirflow API-ServerAirflow A...Any Branch LegacyBackend SystemAny Branch Lega...Distributed Airflow ArchitectureDistributed Airflow ArchitectureInternet Based ClientInternet Based C...Airflow Celery Worker (Pool)Airflow Cel...Edge WorkerEdge WorkerText 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 EcosystemClient(s)Airflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)DBTable: Edge JobTask Instance KeyStateQueueCommand(...)Table: Worker StatusHostnameStatus(...)AirflowSchedulerProvider Package: Edge3EdgeExecutorAdd / Report / CleanupAirflowAPI-ServerProvider Package: Edge3 Executor PluginView(s): Edge Worker - State, Job, MaintenanceQueryQuery / UpdateHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)UpdateUpdateEdgeWorkerProvider Package: Edge3CLI: `airflow edge worker ...`- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)Task Execution via Task SDKTable: Edge LogsTask Instance KeyTimestampLog Text ChunkInsertLogsDAG SyncInternet Based Client(s)HTTPSQueryHTTPSProxyTask SDK API EndpointFirewall/AppGW/Ingress +Corporate Network(s) / Remote Location(s)Corporate Network(s) / Remote Location(s)Airflow Main Data Center or Cloud Deployment EcosystemAirflow Main Data Center or Cloud Deployment Ecosystem    Client(s)...Airflow Edge Worker Components / Provider PackageAirflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)Airflo...DBDBTable: Edge JobTable: Edge JobTask Instance KeyTask Instance KeyStateStateQueueQueueCommandCommand(...)(...)Table: Worker StatusTable: Worker StatusHostnameHostnameStatusStatus(...)(...)AirflowSchedulerAirflo...Provider Package: Edge3Provider Package: Edge3EdgeExecutorEdgeExecutorAdd / Report / CleanupAdd / Report / CleanupAirflowAPI-ServerAirf...Provider Package: Edge3 Executor PluginProvider Package:...View(s): Edge Worker - State, Job, MaintenanceView(s): Edge Worker -...QueryQueryQuery / UpdateQuery / UpdateHTTPSHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)REST API(s) Endpoints:...UpdateUpdateUpdateUpdateEdgeWorkerEdge...Provider Package: Edge3CLI: `airflow edge worker ...`Provider Package: Edge3...- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)- Poll & report job sta...Task Execution via Task SDKTask Execution...Table: Edge LogsTable: Edge LogsTask Instance KeyTask Instance KeyTimestampTimestampLog Text ChunkLog Text ChunkInsertInsertLogsLogsDAG SyncDAG SyncInternet Based Client(s)Internet...HTTPSHTTPSQueryQueryHTTPSHTTPSProxyProxyTask SDK API EndpointTask SDK API EndpointFirewall/AppGW/IngressFirewal...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 NetworksCorporate NetworksRemote Corporate LocationRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Kubernetes Cluster (optional)Airflow Scheduler& DAG ParserAirflow Sch...Postgres DBPostgres DBHTTPSHTTPSFirewall/AppGW/IngressFirewall/...Edge WorkerEdge WorkerProxyProxyClientClientClientClientClientClientAirflow API-ServerAirflow A...Any Branch LegacyBackend SystemAny Branch Lega...Distributed Airflow ArchitectureDistributed Airflow ArchitectureInternet Based ClientInternet Based C...Airflow Celery Worker (Pool)Airflow Cel...Edge WorkerEdge WorkerText is not SVG - cannot display \ No newline at end of file +Cororate NetworksRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Airflow Scheduler& DAG ParserPostgres DBHTTPSFirewall/AppGW/IngressEdge WorkerProxyClientClientClientAirflow API-ServerAny Branch LegacyBackend SystemDistributed Airflow ArchitectureInternet Based ClientAirflow 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 EcosystemAirflow Main Data Center or Cloud Deployment Ecosystem    Client(s)...Airflow Edge Worker Components / Provider PackageAirflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)Airflo...DBDBTable: Edge JobTable: Edge JobTask Instance KeyTask Instance KeyStateStateQueueQueueCommandCommand(...)(...)Table: Worker StatusTable: Worker StatusHostnameHostnameStatusStatus(...)(...)AirflowSchedulerAirflo...Provider Package: Edge3Provider Package: Edge3EdgeExecutorEdgeExecutorAdd / Report / CleanupAdd / Report / CleanupAirflowAPI-ServerAirf...Provider Package: Edge3 Executor PluginProvider Package:...View(s): Edge Worker - State, Job, MaintenanceView(s): Edge Worker -...QueryQueryQuery / UpdateQuery / UpdateHTTPSHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)REST API(s) Endpoints:...UpdateUpdateUpdateUpdateEdgeWorkerEdge...Provider Package: Edge3CLI: `airflow edge worker ...`Provider Package: Edge3...- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)- Poll & report job sta...Task Execution via Task SDKTask Execution...Table: Edge LogsTable: Edge LogsTask Instance KeyTask Instance KeyTimestampTimestampLog Text ChunkLog Text ChunkInsertInsertLogsLogsDAG SyncDAG SyncInternet Based Client(s)Internet...HTTPSHTTPSQueryQueryHTTPSHTTPSProxyProxyTask SDK API EndpointTask SDK API EndpointFirewall/AppGW/IngressFirewal...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 EcosystemAirflow Main Data Center or Cloud Deployment Ecosystem    Client(s)...Airflow Edge Worker Components / Provider PackageAirflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)Airflo...DBDBTable: Edge JobTable: Edge JobTask Instance KeyTask Instance KeyStateStateQueueQueueCommandCommand(...)(...)Table: Worker StatusTable: Worker StatusHostnameHostnameStatusStatus(...)(...)AirflowSchedulerAirflo...Provider Package: Edge3Provider Package: Edge3EdgeExecutorEdgeExecutorAdd / Report / CleanupAdd / Report / CleanupAirflowAPI-ServerAirf...Provider Package: Edge3 Executor PluginProvider Package:...View(s): Edge Worker - State, Job, MaintenanceView(s): Edge Worker -...QueryQueryQuery / UpdateQuery / UpdateHTTPSHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)REST API(s) Endpoints:...UpdateUpdateUpdateUpdateEdgeWorkerEdge...Provider Package: Edge3CLI: `airflow edge worker ...`Provider Package: Edge3...- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)- Poll & report job sta...Task Execution via Task SDKTask Execution...Table: Edge LogsTable: Edge LogsTask Instance KeyTask Instance KeyTimestampTimestampLog Text ChunkLog Text ChunkInsertInsertLogsLogsDAG SyncDAG SyncInternet Based Client(s)Internet...HTTPSHTTPSQueryQueryHTTPSHTTPSProxyProxyTask SDK API EndpointTask SDK API EndpointFirewall/AppGW/IngressFirewal...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 NetworksRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Airflow Scheduler& DAG ParserPostgres DBHTTPSFirewall/AppGW/IngressEdge WorkerProxyClientClientClientAirflow API-ServerAny Branch LegacyBackend SystemDistributed Airflow ArchitectureInternet Based ClientAirflow Celery Worker (Pool)Edge Worker +Corporate NetworksCorporate NetworksRemote Corporate LocationRemote Corporate LocationAirflow Main Data Center or Cloud Deployment EcosystemAirflow Main Data Center or Cloud Deployment EcosystemKubernetes Cluster (optional)Kubernetes Cluster (optional)Airflow Scheduler& DAG ParserAirflow Sch...Postgres DBPostgres DBHTTPSHTTPSFirewall/AppGW/IngressFirewall/...Edge WorkerEdge WorkerProxyProxyClientClientClientClientClientClientAirflow API-ServerAirflow A...Any Branch LegacyBackend SystemAny Branch Lega...Distributed Airflow ArchitectureDistributed Airflow ArchitectureInternet Based ClientInternet Based Cl...Airflow Celery Worker (Pool)Airflow Cel...Edge WorkerEdge WorkerText 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 EcosystemAirflow Main Data Center or Cloud Deployment Ecosystem    Client(s)...Airflow Edge Worker Components / Provider PackageAirflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)Airflo...DBDBTable: Edge JobTable: Edge JobTask Instance KeyTask Instance KeyStateStateQueueQueueCommandCommand(...)(...)Table: Worker StatusTable: Worker StatusHostnameHostnameStatusStatus(...)(...)AirflowSchedulerAirflo...Provider Package: Edge3Provider Package: Edge3EdgeExecutorEdgeExecutorAdd / Report / CleanupAdd / Report / CleanupAirflowAPI-ServerAirf...Provider Package: Edge3 Executor PluginProvider Package:...View(s): Edge Worker - State, Job, MaintenanceView(s): Edge Worker -...QueryQueryQuery / UpdateQuery / UpdateHTTPSHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)REST API(s) Endpoints:...UpdateUpdateUpdateUpdateEdgeWorkerEdge...Provider Package: Edge3CLI: `airflow edge worker ...`Provider Package: Edge3...- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)- Poll & report job sta...Task Execution via Task SDKTask Execution...Table: Edge LogsTable: Edge LogsTask Instance KeyTask Instance KeyTimestampTimestampLog Text ChunkLog Text ChunkInsertInsertLogsLogsDAG SyncDAG SyncInternet Based Client(s)Internet...HTTPSHTTPSQueryQueryHTTPSHTTPSProxyProxyTask SDK API EndpointTask SDK API EndpointFirewall/AppGW/IngressFirewal...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 EcosystemAirflow Main Data Center or Cloud Deployment Ecosystem Airflow Edge Worker Components / Provider PackageAirflow Edge Worker Components / Provider PackageAirflow Celery Worker(Pool / Hybrid Execution)Airflo...DBDBTable: Edge JobTable: Edge JobTask Instance KeyTask Instance KeyStateStateQueueQueueCommandCommand(...)(...)Table: Worker StatusTable: Worker StatusHostnameHostnameStatusStatus(...)(...)AirflowSchedulerAirflo...Provider Package: Edge3Provider Package: Edge3EdgeExecutorEdgeExecutorAdd / Report / CleanupAdd / Report / CleanupAirflowAPI-ServerAirf...Provider Package: Edge3 Executor PluginProvider Package:...View(s): Edge Worker - State, Job, MaintenanceView(s): Edge Worker -...QueryQueryQuery / UpdateQuery / UpdateHTTPSHTTPSREST API(s) Endpoints:- Fetch Job- Report Result- Heartbeat- Log Upload (...)REST API(s) Endpoints:...UpdateUpdateUpdateUpdateEdgeWorkerEdge...Provider Package: Edge3CLI: `airflow edge worker ...`Provider Package: Edge3...- Poll & report job status- Heartbeat, Maintenance- Send log (chunks)- Poll & report job sta...Task Execution via Task SDKTask Execution...Table: Edge LogsTable: Edge LogsTask Instance KeyTask Instance KeyTimestampTimestampLog Text ChunkLog Text ChunkInsertInsertLogsLogsDAG SyncDAG SyncInternet Based Client(s)Internet...HTTPSHTTPSQueryQueryHTTPSHTTPSProxyProxyTask SDK API EndpointTask SDK API EndpointFirewall/AppGW/IngressFirewal...Client(s)Client(s)Text is not SVG - cannot display \ No newline at end of file