Commit d55bdf8
File tree
- .github
- workflows
- airflow-core
- docs
- administration-and-deployment
- logging-monitoring
- authoring-and-scheduling
- language-sdks
- tutorial
- newsfragments
- src/airflow
- api_fastapi
- core_api
- datamodels
- ui
- openapi
- routes/ui
- services
- public
- ui
- execution_api
- datamodels
- versions
- cli/commands
- example_dags
- plugins
- ui
- openapi-gen/requests
- src
- components
- AssetExpression
- layouts/Details/Grid
- pages
- DagsList
- Dashboard/Stats
- tests/unit
- api_fastapi
- core_api
- datamodels
- routes
- public
- ui
- execution_api/versions
- head
- v2026_04_06
- cli
- commands
- models
- plugins
- utils/log
- airflow-ctl/src/airflowctl/api/datamodels
- airflow-e2e-tests/tests/airflow_e2e_tests/go_sdk_tests
- dev/breeze
- src/airflow_breeze
- commands
- templates
- utils
- tests
- docker-stack-docs
- docker-examples/extending
- add-airflow-configuration
- add-apt-packages
- add-build-essential-extend
- add-providers
- add-pypi-packages-constraints
- add-pypi-packages-uv
- add-pypi-packages
- add-python-venv
- add-requirement-packages
- custom-providers
- embedding-dags
- writable-directory
- generated
- go-sdk
- cmd/airflow-go-pack
- dags
- example/bundle
- concurrentxcom
- pkg/worker
- java-sdk/sdk/src
- main/kotlin/org/apache/airflow/sdk/execution
- test/kotlin/org/apache/airflow/sdk/execution
- providers
- airbyte
- docs
- akeyless
- docs
- alibaba
- docs
- amazon
- docs
- operators/s3
- src/airflow/providers/amazon/aws
- hooks
- operators
- tests
- system/amazon/aws
- unit/amazon/aws
- hooks
- operators
- apache
- cassandra
- docs
- drill
- docs
- druid
- docs
- flink
- docs
- hdfs
- docs
- hive
- docs
- iceberg
- docs
- impala
- docs
- kafka
- docs
- kylin
- docs
- livy
- docs
- pig
- docs
- pinot
- docs
- spark
- docs
- tinkerpop
- docs
- apprise
- docs
- arangodb
- docs
- asana
- docs
- atlassian/jira
- docs
- celery
- docs
- src/airflow/providers/celery
- cli
- tests/unit/celery/cli
- clickhousedb
- docs
- cloudant
- docs
- cncf/kubernetes
- docs
- src/airflow/providers/cncf/kubernetes/executors
- tests/unit/cncf/kubernetes/executors
- cohere
- docs
- common
- ai
- docs
- src/airflow/providers/common/ai
- example_dags
- hooks
- toolsets
- tests/unit/common/ai/hooks
- compat
- docs
- io
- docs
- messaging/docs
- sql
- docs
- databricks
- docs
- connections
- src/airflow/providers/databricks
- hooks
- tests/unit/databricks/hooks
- datadog
- docs
- dbt/cloud
- docs
- dingding
- docs
- discord
- docs
- docker
- docs
- edge3
- docs
- elasticsearch
- docs
- src/airflow/providers/elasticsearch
- hooks
- utils
- tests/unit/elasticsearch
- hooks
- utils
- exasol
- docs
- fab
- docs
- src/airflow/providers/fab
- facebook
- docs
- ftp
- docs
- src/airflow/providers/ftp/hooks
- tests/unit/ftp/hooks
- github
- docs
- git
- docs
- connections
- src/airflow/providers/git/hooks
- tests/unit/git
- bundles
- hooks
- google
- docs
- connections
- operators/cloud
- src/airflow/providers/google
- cloud
- hooks
- operators
- transfers
- tests
- system/google/cloud/bigquery
- unit/google/cloud
- hooks
- operators
- grpc
- docs
- hashicorp
- docs
- http
- docs
- ibm/mq/docs
- imap
- docs
- influxdb
- docs
- informatica
- docs
- jdbc
- docs
- jenkins
- docs
- keycloak
- docs
- auth-manager
- src/airflow/providers/keycloak
- auth_manager
- tests/unit/keycloak/auth_manager
- microsoft
- azure
- docs
- mssql
- docs
- psrp
- docs
- winrm
- docs
- mongo
- docs
- mysql
- docs
- neo4j
- docs
- odbc
- docs
- openai
- docs
- operators
- src/airflow/providers/openai
- hooks
- operators
- tests
- system/openai
- unit/openai
- hooks
- operators
- openfaas
- docs
- openlineage
- docs
- src/airflow/providers/openlineage
- api
- extractors
- plugins
- utils
- tests/unit/openlineage
- api
- extractors
- plugins
- utils
- opensearch
- docs
- opsgenie
- docs
- oracle
- docs
- pagerduty
- docs
- papermill
- docs
- pgvector
- docs
- pinecone
- docs
- postgres
- docs
- presto
- docs
- qdrant
- docs
- redis
- docs
- salesforce
- docs
- samba
- docs
- segment
- docs
- sendgrid
- docs
- sftp
- docs
- singularity
- docs
- slack
- docs
- smtp
- docs
- snowflake
- docs
- src/airflow/providers/snowflake/hooks
- sqlite
- docs
- ssh
- docs
- standard
- docs
- tableau
- docs
- src/airflow/providers/tableau/hooks
- tests/unit/tableau/hooks
- telegram
- docs
- teradata
- docs
- trino
- docs
- vertica
- docs
- vespa
- docs
- weaviate
- docs
- yandex
- docs
- ydb
- docs
- zendesk
- docs
- registry
- scripts/ci
- docker-compose
- prek
- task-sdk
- src/airflow/sdk
- api/datamodels
- coordinators/node
- definitions
- execution_time/schema
- versions
- tests/task_sdk
- coordinators/node
- execution_time
- schema
- ts-sdk
- scripts/ci/prek
- src
- sdk
- tests
- 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 | |
|---|---|---|---|
| |||
162 | 162 | | |
163 | 163 | | |
164 | 164 | | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
165 | 169 | | |
166 | | - | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
167 | 174 | | |
168 | 175 | | |
169 | 176 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
46 | | - | |
47 | | - | |
48 | | - | |
49 | | - | |
50 | | - | |
51 | | - | |
52 | | - | |
53 | | - | |
54 | | - | |
55 | | - | |
56 | | - | |
57 | | - | |
58 | 45 | | |
59 | 46 | | |
60 | 47 | | |
| |||
260 | 247 | | |
261 | 248 | | |
262 | 249 | | |
263 | | - | |
264 | | - | |
265 | | - | |
266 | | - | |
267 | | - | |
268 | | - | |
269 | | - | |
270 | | - | |
271 | | - | |
272 | | - | |
273 | | - | |
274 | | - | |
275 | | - | |
276 | | - | |
277 | | - | |
278 | | - | |
279 | | - | |
280 | | - | |
281 | | - | |
282 | | - | |
283 | | - | |
284 | | - | |
285 | | - | |
286 | | - | |
287 | | - | |
288 | | - | |
289 | | - | |
290 | | - | |
291 | | - | |
292 | | - | |
293 | | - | |
294 | | - | |
295 | | - | |
296 | 250 | | |
297 | 251 | | |
298 | 252 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
30 | | - | |
31 | | - | |
32 | | - | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
33 | 34 | | |
34 | 35 | | |
35 | 36 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
30 | 34 | | |
31 | 35 | | |
32 | 36 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
88 | 88 | | |
89 | 89 | | |
90 | 90 | | |
91 | | - | |
| 91 | + | |
92 | 92 | | |
93 | 93 | | |
94 | 94 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
136 | 136 | | |
137 | 137 | | |
138 | 138 | | |
139 | | - | |
140 | | - | |
| 139 | + | |
| 140 | + | |
141 | 141 | | |
142 | 142 | | |
143 | 143 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
249 | 249 | | |
250 | 250 | | |
251 | 251 | | |
| 252 | + | |
| 253 | + | |
| 254 | + | |
| 255 | + | |
| 256 | + | |
| 257 | + | |
| 258 | + | |
| 259 | + | |
| 260 | + | |
| 261 | + | |
| 262 | + | |
| 263 | + | |
| 264 | + | |
| 265 | + | |
| 266 | + | |
252 | 267 | | |
253 | 268 | | |
254 | 269 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
160 | 160 | | |
161 | 161 | | |
162 | 162 | | |
| 163 | + | |
| 164 | + | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
163 | 168 | | |
164 | 169 | | |
165 | 170 | | |
| |||
Lines changed: 18 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
64 | 82 | | |
65 | 83 | | |
66 | 84 | | |
| |||
Lines changed: 36 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
115 | 115 | | |
116 | 116 | | |
117 | 117 | | |
| 118 | + | |
| 119 | + | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
| 123 | + | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
| 128 | + | |
| 129 | + | |
| 130 | + | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
| 134 | + | |
| 135 | + | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
| 140 | + | |
| 141 | + | |
| 142 | + | |
| 143 | + | |
| 144 | + | |
| 145 | + | |
| 146 | + | |
| 147 | + | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
| 151 | + | |
| 152 | + | |
| 153 | + | |
118 | 154 | | |
119 | 155 | | |
120 | 156 | | |
| |||
0 commit comments