Repository navigation
Commit 77fa2ed
committed
File tree
- .agents/skills/airflow-translations
- locales
- .apache-magpie-overrides
- .github/workflows
- airflow-core
- adr/lang-sdk
- docs
- administration-and-deployment
- authoring-and-scheduling
- language-sdks
- core-concepts
- newsfragments
- src/airflow
- api_fastapi
- auth/managers/simple/ui
- common
- parameters
- core_api
- datamodels
- ui
- openapi
- routes
- public
- ui
- services
- public
- ui
- execution_api
- datamodels
- routes
- versions
- logging
- assets
- cli/commands
- config_templates
- dag_processing
- example_dags
- executors
- workloads
- jobs
- migrations
- versions
- models
- serialization
- definitions
- state
- ti_deps
- deps
- timetables
- ui
- openapi-gen
- queries
- requests
- public/i18n/locales
- ar
- ca
- de
- el
- en
- es
- fr
- he
- hi
- hu
- it
- ja
- ko
- nl
- pl
- pt
- ru
- th
- tr
- zh-CN
- zh-TW
- src
- components
- ActionAccordion
- Breadcrumb
- Clear/TaskInstance
- DagActions
- DataTable
- Graph
- MarkAs/TaskInstance
- constants
- hooks
- i18n
- layouts/Details
- Gantt
- Grid
- pages
- Asset/AssetStateStore
- DagsList
- Dag
- Calendar
- Code
- Tasks
- Versions
- Events
- GroupTaskInstance
- LoopIterations
- HITLTaskInstances
- Run
- TaskInstances
- TaskInstance
- Logs
- TaskStateStore
- Task
- Overview
- XCom
- queries
- utils
- tests/e2e
- fixtures
- pages
- specs
- utils
- log
- tests/unit
- always
- api_fastapi
- common
- core_api
- routes
- public
- ui
- services/ui
- execution_api
- versions
- head
- v2026_10_30
- logging
- assets
- callbacks
- cli/commands
- dag_processing
- lang_sdk_fixtures
- executors
- jobs
- migrations
- models
- plugins
- serialization
- definitions
- state
- ti_deps/deps
- timetables
- utils
- log
- airflow-ctl
- src/airflowctl
- api/datamodels
- ctl
- tests/airflow_ctl
- api
- ctl
- commands
- airflow-e2e-tests
- docker
- java-native-bundle
- src/java/org/apache/airflow/e2e
- nativedag
- tests/airflow_e2e_tests
- e2e_test_utils
- go_sdk_tests
- java_sdk_tests
- ts_sdk_tests
- contributing-docs
- devel-common
- src
- sphinx_exts
- templates
- tests_common
- test_utils
- tests/unit/sphinx_exts
- dev
- breeze
- doc
- ci
- images
- src/airflow_breeze
- commands
- utils
- tests
- react-plugin-tools/react_plugin_template
- docs
- go-sdk
- airflow
- example/native
- internal
- bundle
- genspec
- pkg/execution
- genmodels
- schema
- java-sdk
- example/src/java/org/apache/airflow/example
- nativedag
- plugin
- src
- main/kotlin/org/apache/airflow/sdk/plugin
- test/kotlin/org/apache/airflow/sdk/plugin
- processor/src
- main/kotlin/org/apache/airflow/sdk
- test/kotlin/org/apache/airflow/sdk
- scripts/ci/prek
- sdk
- schema
- src
- main/kotlin/org/apache/airflow/sdk
- execution
- internal
- test/kotlin/org/apache/airflow
- example
- sdk
- conformance
- execution
- internal
- kubernetes-tests
- lang_sdk
- config
- dags
- go_example
- java_example/src/java/org/apache/airflow/k8sexample
- pod_templates
- ts_example
- src
- tests/kubernetes_tests
- providers
- airbyte
- docs
- src/airflow/providers/airbyte
- akeyless
- docs
- src/airflow/providers/akeyless
- alibaba
- docs
- src/airflow/providers/alibaba
- amazon
- docs
- auth-manager/setup
- transfer
- src/airflow/providers/amazon
- aws
- auth_manager/routes
- transfers
- tests
- system/amazon/aws
- tests
- unit/amazon/aws
- auth_manager/routes
- executors
- batch
- ecs
- anthropic
- docs
- src/airflow/providers/anthropic
- apache
- arrow
- docs
- src/airflow/providers/apache/arrow
- beam
- docs
- src/airflow/providers/apache/beam
- cassandra
- docs
- src/airflow/providers/apache/cassandra
- drill
- docs
- src/airflow/providers/apache/drill
- druid
- docs
- src/airflow/providers/apache/druid
- flink
- docs
- src/airflow/providers/apache/flink
- hdfs
- docs
- src/airflow/providers/apache/hdfs
- hive
- docs
- src/airflow/providers/apache/hive
- iceberg
- docs
- src/airflow/providers/apache/iceberg
- impala
- docs
- src/airflow/providers/apache/impala
- kafka
- docs
- src/airflow/providers/apache/kafka
- kylin
- docs
- src/airflow/providers/apache/kylin
- livy
- docs
- src/airflow/providers/apache/livy
- pig
- docs
- src/airflow/providers/apache/pig
- pinot
- docs
- src/airflow/providers/apache/pinot
- spark
- docs
- src/airflow/providers/apache/spark
- hooks
- tests/unit/apache/spark/hooks
- tinkerpop
- docs
- src/airflow/providers/apache/tinkerpop
- apprise
- docs
- src/airflow/providers/apprise
- arangodb
- docs
- src/airflow/providers/arangodb
- asana
- docs
- src/airflow/providers/asana
- atlassian/jira
- docs
- src/airflow/providers/atlassian/jira
- celery
- docs
- src/airflow/providers/celery
- clickhousedb
- docs
- src/airflow/providers/clickhousedb
- cloudant
- docs
- src/airflow/providers/cloudant
- cncf/kubernetes
- docs
- src/airflow/providers/cncf/kubernetes
- executors
- tests/unit/cncf/kubernetes
- executors
- operators
- cohere
- docs
- src/airflow/providers/cohere
- common
- ai
- docs
- connections
- operators
- toolsets
- src/airflow/providers/common/ai
- durable
- example_dags
- hooks
- mixins
- operators
- plugins
- www
- src
- components
- hooks
- tests
- toolsets
- tools
- utils
- tests/unit/common/ai
- decorators
- durable
- managed_agents
- mixins
- operators
- plugins
- policies
- sandbox
- toolsets
- tools
- utils
- compat
- docs
- src/airflow/providers/common/compat
- io
- docs
- src/airflow/providers/common/io
- state_store
- tests/unit/common/io/state_store
- messaging
- docs
- src/airflow/providers/common/messaging
- sql
- docs
- src/airflow/providers/common/sql
- databricks
- docs
- src/airflow/providers/databricks
- datadog
- docs
- src/airflow/providers/datadog
- dbt/cloud
- docs
- src/airflow/providers/dbt/cloud
- dingding
- docs
- src/airflow/providers/dingding
- discord
- docs
- src/airflow/providers/discord
- docker
- docs
- src/airflow/providers/docker
- duckdb
- docs
- src/airflow/providers/duckdb
- edge3
- docs
- src/airflow/providers/edge3
- cli
- worker_api
- routes
- tests/unit/edge3
- cli
- worker_api/routes
- elasticsearch
- docs
- src/airflow/providers/elasticsearch
- log
- tests/unit/elasticsearch/log
- exasol
- docs
- src/airflow/providers/exasol
- fab
- docs
- src/airflow/providers/fab
- auth_manager
- tests/unit/fab/auth_manager
- facebook
- docs
- src/airflow/providers/facebook
- ftp
- docs
- src/airflow/providers/ftp
- github
- docs
- src/airflow/providers/github
- git
- docs
- src/airflow/providers/git
- google
- docs
- src/airflow/providers/google
- cloud/operators
- tests/unit/google/cloud/operators
- grpc
- docs
- src/airflow/providers/grpc
- hashicorp
- docs
- src/airflow/providers/hashicorp
- http
- docs
- src/airflow/providers/http
- ibm
- db2
- mq
- imap
- docs
- src/airflow/providers/imap
- influxdb
- docs
- src/airflow/providers/influxdb
- informatica
- docs
- src/airflow/providers/informatica
- jdbc
- docs
- src/airflow/providers/jdbc
- jenkins
- docs
- src/airflow/providers/jenkins
- keycloak
- docs
- src/airflow/providers/keycloak
- microsoft
- azure
- docs
- src/airflow/providers/microsoft/azure
- mssql
- docs
- src/airflow/providers/microsoft/mssql
- psrp
- docs
- src/airflow/providers/microsoft/psrp
- winrm
- docs
- src/airflow/providers/microsoft/winrm
- modal
- mongo
- docs
- src/airflow/providers/mongo
- mysql
- docs
- src/airflow/providers/mysql
- neo4j
- docs
- src/airflow/providers/neo4j
- odbc
- docs
- src/airflow/providers/odbc
- openai
- docs
- src/airflow/providers/openai
- openfaas
- docs
- src/airflow/providers/openfaas
- openlineage
- docs
- src/airflow/providers/openlineage
- plugins
- utils
- tests/unit/openlineage
- plugins
- utils
- opensearch
- docs
- src/airflow/providers/opensearch
- log
- tests/unit/opensearch/log
- opsgenie
- docs
- src/airflow/providers/opsgenie
- oracle
- docs
- src/airflow/providers/oracle
- pagerduty
- docs
- src/airflow/providers/pagerduty
- papermill
- docs
- src/airflow/providers/papermill
- pgvector
- docs
- src/airflow/providers/pgvector
- pinecone
- docs
- src/airflow/providers/pinecone
- postgres
- docs
- src/airflow/providers/postgres
- presto
- docs
- src/airflow/providers/presto
- qdrant
- docs
- src/airflow/providers/qdrant
- redis
- docs
- src/airflow/providers/redis
- salesforce
- docs
- src/airflow/providers/salesforce
- samba
- docs
- src/airflow/providers/samba
- segment
- docs
- src/airflow/providers/segment
- sendgrid
- docs
- src/airflow/providers/sendgrid
- sftp
- docs
- src/airflow/providers/sftp
- singularity
- docs
- src/airflow/providers/singularity
- slack
- docs
- src/airflow/providers/slack
- smtp
- docs
- src/airflow/providers/smtp
- snowflake
- docs
- operators
- src/airflow/providers/snowflake
- operators
- tests
- system/snowflake
- unit/snowflake/operators
- sqlite
- docs
- src/airflow/providers/sqlite
- ssh
- docs
- src/airflow/providers/ssh
- standard
- docs
- src/airflow/providers/standard
- tableau
- docs
- src/airflow/providers/tableau
- telegram
- docs
- src/airflow/providers/telegram
- teradata
- docs
- src/airflow/providers/teradata
- trino
- docs
- src/airflow/providers/trino
- vertica
- docs
- src/airflow/providers/vertica
- vespa
- docs
- src/airflow/providers/vespa
- weaviate
- docs
- src/airflow/providers/weaviate
- yandex
- docs
- src/airflow/providers/yandex
- ydb
- docs
- src/airflow/providers/ydb
- zendesk
- docs
- src/airflow/providers/zendesk
- registry
- scripts
- ci
- lang_sdk_serialization
- prek
- docker
- tests/ci/prek
- task-sdk
- docs
- src/airflow/sdk
- api
- datamodels
- bases
- coordinators/java
- definitions
- _internal
- asset
- decorators
- timetables
- execution_time
- schema
- versions
- importers/yaml_importer
- versions
- tests
- task_sdk
- bases
- coordinators/java
- definitions
- _internal
- decorators
- timetables
- execution_time
- schema
- importers/yaml_importer
- ts-sdk
- adr
- api-docs
- docs
- example
- dags
- src
- schema
- scripts
- ci/prek
- src
- coordinator
- generated
- hitl
- sdk
- tests
- coordinator
- hitl
- sdk
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
184 | 184 | | |
185 | 185 | | |
186 | 186 | | |
| 187 | + | |
| 188 | + | |
| 189 | + | |
| 190 | + | |
187 | 191 | | |
188 | 192 | | |
189 | 193 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
79 | 79 | | |
80 | 80 | | |
81 | 81 | | |
82 | | - | |
| 82 | + | |
83 | 83 | | |
84 | | - | |
| 84 | + | |
85 | 85 | | |
86 | 86 | | |
87 | 87 | | |
| |||
134 | 134 | | |
135 | 135 | | |
136 | 136 | | |
137 | | - | |
138 | | - | |
139 | | - | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
140 | 140 | | |
141 | 141 | | |
142 | 142 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
189 | 189 | | |
190 | 190 | | |
191 | 191 | | |
192 | | - | |
| 192 | + | |
193 | 193 | | |
194 | 194 | | |
195 | 195 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
220 | 220 | | |
221 | 221 | | |
222 | 222 | | |
223 | | - | |
| 223 | + | |
224 | 224 | | |
225 | 225 | | |
226 | 226 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
220 | 220 | | |
221 | 221 | | |
222 | 222 | | |
223 | | - | |
| 223 | + | |
224 | 224 | | |
225 | 225 | | |
226 | 226 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
221 | 221 | | |
222 | 222 | | |
223 | 223 | | |
224 | | - | |
| 224 | + | |
225 | 225 | | |
226 | 226 | | |
227 | 227 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
173 | 173 | | |
174 | 174 | | |
175 | 175 | | |
176 | | - | |
| 176 | + | |
177 | 177 | | |
178 | 178 | | |
179 | 179 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
101 | 101 | | |
102 | 102 | | |
103 | 103 | | |
104 | | - | |
| 104 | + | |
105 | 105 | | |
106 | 106 | | |
107 | 107 | | |
| |||
187 | 187 | | |
188 | 188 | | |
189 | 189 | | |
190 | | - | |
| 190 | + | |
191 | 191 | | |
192 | 192 | | |
193 | 193 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
103 | 103 | | |
104 | 104 | | |
105 | 105 | | |
106 | | - | |
| 106 | + | |
107 | 107 | | |
108 | 108 | | |
109 | 109 | | |
| |||
176 | 176 | | |
177 | 177 | | |
178 | 178 | | |
179 | | - | |
| 179 | + | |
180 | 180 | | |
181 | 181 | | |
182 | 182 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
91 | 91 | | |
92 | 92 | | |
93 | 93 | | |
94 | | - | |
| 94 | + | |
95 | 95 | | |
96 | 96 | | |
97 | 97 | | |
| |||
0 commit comments