Open source · Apache Airflow

Apache Airflow contributions for AI agents.

I contribute provider capabilities to Apache Airflow, with an emphasis on AI agent lifecycle orchestration, Kubernetes operations and the details that make integrations reliable in real DAGs.

13Pull requests authored

9Merged upstream

3Agent clouds covered

Public GitHub snapshot · August 9, 2026

Now in review

Extending where Airflow can operate.

Open upstream PR

Kubernetes · Existing Pods

KubernetesPodExecOperator

Executes commands inside an already-running container without creating, restarting or deleting its Pod, preserving pre-warmed workloads and avoiding startup latency.

apache/airflow#71244 ↗

Open upstream PR

Google Cloud · Vertex AI Agent Engine

Synchronous agent queries

Adds direct synchronous Reasoning Engine queries for DAGs that do not need a GCS-backed asynchronous query job or its extra lifecycle.

apache/airflow#70933 ↗

Selected impact

One orchestration layer, three agent clouds.

AWS

Bedrock AgentCore Runtime

Create · Invoke · DeletePR #67984

Google Cloud

Vertex AI Agent Engine

Create · Get · Query · Update · DeletePR #68479

Microsoft Azure

AI Foundry Agents

Create · Update · Run · DeletePR #68799

These integrations let a DAG manage a cloud agent runtime as an explicit lifecycle: provision it, invoke or query it, update it when supported and clean it up. The Agentic Airflow Demo exercises the three paths through the same troubleshooting workflow. Beyond agent runtimes, the merged DmsModifyTaskOperator and DmsReloadTablesOperator make task modification and selective table reload first-class Airflow operations. The reload path includes synchronous and deferrable waits and an end-to-end AWS system test.

Contribution record

The public trail.

#71244Add KubernetesPodExecOperator for existing Kubernetes PodsKubernetes · Pod executionOpen #70933Add synchronous Vertex AI Agent Engine query operatorGoogle Cloud · Vertex AI Agent EngineOpen #70569Add DmsReloadTablesOperatorAWS DMSMerged #70160Add Oracle Cloud Infrastructure connection and Generative AI hookOCI · Generative AIOpen #69930Add dedicated Glue crawler lifecycle operatorsAWS GlueMerged #69886Add Amazon ECR repository operatorsAmazon ECRMerged #69386Log SQL query on its own line in BigQueryInsertJobOperatorGoogle BigQueryMerged #68953Fix Breeze SIGILL on Apple Silicon caused by OpenSSL ARM crypto instructionsDeveloper experienceClosed #68799Add Azure AI Foundry Agents operators (Create, Update, Delete, Run)Microsoft Azure · AI agentsMerged #68479Add Vertex AI Agent Engine operators (Create, Get, Query, Update, Delete)Google Cloud · AI agentsMerged #68140Wait for Bedrock AgentCore Runtime deletionAWS · AI agentsMerged #67984Add Amazon Bedrock AgentCore Runtime operatorsAWS · AI agentsMerged #67524Add DmsModifyTaskOperatorAWS DMSMerged