Commit c752a20
File tree
- .devcontainer
- mysql
- postgres
- .github
- ISSUE_TEMPLATE
- actions
- breeze
- install-prek
- migration_tests
- instructions
- skills/airflow-translations
- locales
- workflows
- airflow-core
- docs
- administration-and-deployment
- logging-monitoring
- authoring-and-scheduling
- core-concepts
- auth-manager
- simple
- executor
- howto
- docker-compose
- img
- installation
- security
- secrets/secrets-backend
- tutorial
- newsfragments
- src/airflow
- api_fastapi
- auth
- managers
- models
- simple
- openapi
- routes
- services
- ui
- openapi-gen/requests
- src
- login
- middlewares
- common
- db
- core_api
- datamodels
- ui
- openapi
- routes
- public
- ui
- services
- public
- ui
- execution_api
- datamodels
- routes
- versions
- logging
- api/common
- assets
- cli
- commands
- config_templates
- dag_processing
- bundles
- datasets
- example_dags
- executors
- workloads
- jobs
- listeners
- spec
- migrations
- versions
- models
- observability
- metrics
- operators
- partition_mappers
- secrets
- serialization
- definitions
- ti_deps/deps
- timetables
- triggers
- ui
- openapi-gen
- queries
- requests
- public/i18n
- locales
- ca
- de
- en
- hi
- hu
- ko
- pl
- ru
- tr
- zh-CN
- zh-TW
- src
- components
- AssetExpression
- Assets
- Banner
- DataTable
- FlexibleForm
- Graph
- MarkAs/Run
- SearchDags
- TriggerDag
- ui
- Pagination
- constants
- context
- openGroups
- timezone
- hooks
- i18n
- layouts
- Details
- Gantt
- Graph
- Grid
- mocks/handlers
- pages
- AssetsList
- Asset
- Connections
- DagsList
- DagsFilters
- Dag
- Calendar
- Overview
- Dashboard
- HistoricalMetrics
- PoolSummary
- Stats
- Events
- GroupTaskInstance
- MappedTaskInstance
- Pools
- Run
- TaskInstance
- Logs
- Variables
- XCom
- queries
- utils
- tests/e2e
- pages
- specs
- utils
- log
- serve_logs
- tests
- integration/otel
- dags
- unit
- always
- api_fastapi
- auth
- managers
- simple
- services
- middlewares
- common
- core_api
- routes
- public
- ui
- services/ui
- execution_api
- versions
- head
- v2026_03_31
- api/common
- assets
- charts
- cli/commands
- config_templates
- core
- dag_processing
- bundles
- datasets
- executors
- jobs
- listeners
- models
- observability
- metrics
- traces
- partition_mappers
- plugins
- serialization
- ti_deps/deps
- timetables
- triggers
- utils
- log
- airflow-ctl-tests
- tests/airflowctl_tests
- airflow-ctl
- docs
- howto
- images
- installation
- src/airflowctl
- api
- datamodels
- ctl
- commands
- tests/airflow_ctl
- api
- ctl
- commands
- airflow-e2e-tests
- docker
- scripts
- tests/airflow_e2e_tests
- e2e_test_utils
- remote_log_elasticsearch_tests
- remote_log_tests
- xcom_object_storage_tests
- chart
- dockerfiles/pgbouncer-exporter
- docs
- files
- templates
- api-server
- cleanup
- configmaps
- dag-processor
- database-cleanup
- flower
- jobs
- pgbouncer
- rbac
- redis
- scheduler
- secrets
- statsd
- triggerer
- webserver
- workers
- clients/python
- contributing-docs
- quick-start-ide
- testing
- devel-common
- src
- docs
- utils
- sphinx_exts
- docs_build
- pagefind_search
- templates
- tests_common
- test_utils
- dev
- airflow_perf
- backport
- breeze
- doc
- adr
- ci
- images
- src/airflow_breeze
- commands
- params
- prepare_providers
- templates
- utils
- tests
- integration_tests
- ide_setup
- react-plugin-tools/react_plugin_template
- registry
- registry_tools
- tests
- stats
- system_tests
- docker-stack-docs
- docker-examples
- customizing
- 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-requirement-packages
- custom-providers
- embedding-dags
- writable-directory
- restricted
- docker-images-recipes
- docker-tests
- tests/docker_tests
- docs
- generated
- go-sdk
- edge
- pkg
- api
- edgeapi
- helm-tests
- tests
- chart_utils
- helm_tests
- airflow_aux
- airflow_core
- apiserver
- other
- security
- webserver
- kubernetes-tests
- tests/kubernetes_tests
- performance
- providers-summary-docs
- operators-and-hooks-ref
- providers
- airbyte
- docs
- src/airflow/providers/airbyte
- hooks
- tests/unit/airbyte/hooks
- alibaba
- docs
- connections
- src/airflow/providers/alibaba
- amazon
- docs
- auth-manager/setup
- connections
- operators
- s3
- src/airflow/providers/amazon
- aws
- auth_manager
- routes
- executors
- aws_lambda
- ecs
- hooks
- log
- operators
- transfers
- triggers
- utils
- tests
- system/amazon/aws
- unit/amazon/aws
- auth_manager
- executors
- aws_lambda
- ecs
- hooks
- log
- operators
- transfers
- triggers
- apache
- beam
- docs
- integration-logos
- src/airflow/providers/apache/beam
- cassandra
- docs
- connections
- src/airflow/providers/apache/cassandra
- drill
- docs
- src/airflow/providers/apache/drill
- tests/unit/apache/drill/hooks
- druid
- docs
- src/airflow/providers/apache/druid
- tests/unit/apache/druid/hooks
- flink
- docs
- src/airflow/providers/apache/flink
- hdfs
- docs
- hive
- docs
- connections
- src/airflow/providers/apache/hive
- hooks
- transfers
- tests
- system/apache/hive
- unit/apache/hive/hooks
- iceberg
- docs
- src/airflow/providers/apache/iceberg
- hooks
- tests
- system/apache/iceberg
- unit/apache/iceberg/hooks
- impala
- docs
- integration-logos
- src/airflow/providers/apache/impala
- tests/unit/apache/impala/hooks
- kafka
- docs
- connections
- src/airflow/providers/apache/kafka
- sensors
- triggers
- tests/unit/apache/kafka
- sensors
- triggers
- kylin
- docs
- livy
- docs
- src/airflow/providers/apache/livy/hooks
- tests/unit/apache/livy/hooks
- pig
- docs
- pinot
- docs
- src/airflow/providers/apache/pinot
- hooks
- tests/unit/apache/pinot/hooks
- spark
- docs
- connections
- src/airflow/providers/apache/spark
- hooks
- operators
- tests/unit/apache/spark
- hooks
- operators
- tinkerpop
- docs
- connections
- integration-logos
- src/airflow/providers/apache/tinkerpop
- apprise
- docs
- src/airflow/providers/apprise
- arangodb
- docs
- integration-logos
- src/airflow/providers/arangodb
- asana
- docs
- connections
- integration-logos
- src/airflow/providers/asana
- atlassian/jira
- docs
- celery
- docs
- src/airflow/providers/celery
- cli
- executors
- tests
- integration/celery
- unit/celery
- cli
- executors
- cloudant
- docs
- src/airflow/providers/cloudant
- tests/unit/cloudant/hooks
- cncf/kubernetes
- docs
- secrets-backends
- src/airflow/providers/cncf/kubernetes
- cli
- decorators
- executors
- hooks
- operators
- secrets
- triggers
- utils
- tests/unit/cncf/kubernetes
- executors
- hooks
- operators
- secrets
- triggers
- utils
- cohere
- docs
- src/airflow/providers/cohere
- common
- ai
- docs
- connections
- hooks
- operators
- src/airflow
- providers
- common
- ai
- decorators
- example_dags
- hooks
- mixins
- operators
- plugins
- www
- src
- components
- hooks
- types
- toolsets
- triggers
- utils
- tests
- system
- common
- ai
- unit
- common
- ai
- decorators
- hooks
- mixins
- operators
- plugins
- toolsets
- triggers
- utils
- compat
- docs
- src/airflow/providers/common/compat
- security
- standard
- tests/unit/common/compat
- io
- docs
- messaging
- docs
- sql
- docs
- src/airflow/providers/common/sql
- datafusion
- decorators
- example_dags
- hooks
- operators
- triggers
- tests
- system/common/sql
- unit/common/sql
- datafusion
- decorators
- hooks
- operators
- databricks
- docs
- connections
- src/airflow/providers/databricks
- hooks
- operators
- utils
- tests
- system/databricks
- unit/databricks
- hooks
- operators
- plugins
- utils
- datadog
- docs
- connections
- src/airflow/providers/datadog
- dbt/cloud
- docs
- src/airflow/providers/dbt/cloud
- hooks
- operators
- triggers
- tests/unit/dbt/cloud
- hooks
- operators
- triggers
- dingding
- docs
- discord
- docs
- connections
- src/airflow/providers/discord
- docker
- docs
- src/airflow/providers/docker
- operators
- edge3
- docs
- src/airflow/providers/edge3
- cli
- executors
- migrations
- versions
- models
- plugins
- www
- dist
- openapi-gen
- queries
- requests
- src
- components
- ui
- hooks
- layouts
- pages
- utils
- worker_api
- routes
- tests
- unit/edge3
- cli
- migrations
- models
- plugins
- worker_api/routes
- elasticsearch
- docs
- src/airflow/providers/elasticsearch
- log
- tests
- integration
- elasticsearch
- log
- unit/elasticsearch
- hooks
- log
- elasticmock
- exasol
- docs
- src/airflow/providers/exasol
- hooks
- tests/unit/exasol/hooks
- fab
- docs
- api-ref
- auth-manager
- src/airflow/providers/fab
- auth_manager
- api_endpoints
- api_fastapi
- datamodels
- openapi
- routes
- services
- cli_commands
- models
- openapi
- schemas
- security_manager
- views
- cli
- migrations/versions
- www
- api_connexion
- extensions
- static
- dist
- tests
- unit/fab
- auth_manager
- api_endpoints
- api_fastapi
- datamodels
- routes
- services
- cli_commands
- models
- schemas
- security_manager
- views
- db_manager
- www/views
- facebook
- docs
- ftp
- docs
- github
- docs
- integration-logos
- src/airflow/providers/github
- git
- docs
- connections
- integration-logos
- src/airflow/providers/git
- bundles
- hooks
- tests/unit/git
- bundles
- hooks
- google
- docs
- connections
- integration-logos
- operators
- cloud
- marketing_platform
- secrets-backends
- src/airflow/providers/google
- ads
- hooks
- transfers
- cloud
- _internal_client
- fs
- hooks
- vertex_ai
- links
- log
- operators
- vertex_ai
- transfers
- triggers
- utils
- common
- auth_backend
- hooks
- marketing_platform
- hooks
- operators
- sensors
- tests
- system/google
- cloud
- azure
- cloud_run
- compute
- dataform
- dataplex
- dataproc
- gcs
- gen_ai
- ray
- storage_transfer
- vision
- marketing_platform
- unit/google
- ads
- hooks
- transfers
- cloud
- fs
- hooks
- vertex_ai
- links
- log
- operators
- vertex_ai
- sensors
- transfers
- triggers
- utils
- common/auth_backend
- marketing_platform
- hooks
- operators
- sensors
- grpc
- docs
- connections
- integration-logos
- src/airflow/providers/grpc
- hashicorp
- docs
- secrets-backends
- src/airflow/providers/hashicorp
- _internal_client
- hooks
- secrets
- tests/unit/hashicorp
- _internal_client
- hooks
- secrets
- http
- docs
- src/airflow/providers/http
- hooks
- operators
- triggers
- tests/unit/http
- hooks
- operators
- triggers
- imap
- docs
- src/airflow/providers/imap
- hooks
- tests/unit/imap/hooks
- influxdb
- docs
- integration-logos
- src/airflow/providers/influxdb
- informatica
- docs
- guides
- integration-logos
- src/airflow
- providers
- informatica
- extractors
- hooks
- plugins
- tests
- unit
- informatica
- extractors
- hooks
- plugins
- jdbc
- docs
- src/airflow/providers/jdbc
- hooks
- tests/unit/jdbc/hooks
- jenkins
- docs
- src/airflow/providers/jenkins
- keycloak
- docs
- auth-manager/manage
- integration-logos
- src/airflow/providers/keycloak
- auth_manager
- cli
- openapi
- routes
- cli
- tests/unit/keycloak
- auth_manager
- cli
- routes
- cli
- microsoft
- azure
- docs
- connections
- message-queues
- operators
- src/airflow/providers/microsoft/azure
- hooks
- operators
- queues
- sensors
- triggers
- tests
- system/microsoft/azure
- unit/microsoft/azure
- hooks
- operators
- queues
- sensors
- triggers
- mssql
- docs
- src/airflow/providers/microsoft/mssql
- tests/unit/microsoft/mssql/hooks
- psrp
- docs
- winrm
- docs
- src/airflow/providers/microsoft/winrm
- hooks
- operators
- triggers
- tests/unit/microsoft/winrm
- hooks
- operators
- triggers
- mongo
- docs
- src/airflow/providers/mongo
- mysql
- docs
- src/airflow/providers/mysql
- hooks
- tests/unit/mysql/hooks
- neo4j
- docs
- integration-logos
- src/airflow/providers/neo4j
- odbc
- docs
- connections
- src/airflow/providers/odbc
- tests/unit/odbc/hooks
- openai
- docs
- integration-logos
- src/airflow/providers/openai
- openfaas
- docs
- src/airflow/providers/openfaas
- openlineage
- docs
- guides
- src/airflow/providers/openlineage
- extractors
- plugins
- utils
- tests/unit/openlineage
- extractors
- plugins
- utils
- opensearch
- docs
- connections
- src/airflow/providers/opensearch
- tests/unit/opensearch/log
- opsgenie
- docs
- src/airflow/providers/opsgenie
- oracle
- docs
- src/airflow/providers/oracle
- hooks
- tests/unit/oracle/hooks
- pagerduty
- docs
- connections
- src/airflow/providers/pagerduty
- papermill
- docs
- pgvector
- docs
- src/airflow/providers/pgvector
- tests/unit/pgvector/hooks
- pinecone
- docs
- integration-logos
- src/airflow/providers/pinecone
- postgres
- docs
- src/airflow/providers/postgres
- hooks
- tests/unit/postgres/hooks
- presto
- docs
- src/airflow/providers/presto
- tests/unit/presto/hooks
- qdrant
- docs
- integration-logos
- src/airflow/providers/qdrant
- redis
- docs
- logging
- src/airflow/providers/redis
- salesforce
- docs
- connections
- src/airflow/providers/salesforce
- operators
- samba
- docs
- src/airflow/providers/samba
- segment
- docs
- sendgrid
- docs
- sftp
- docs
- src/airflow/providers/sftp
- fs
- operators
- tests/unit/sftp/operators
- singularity
- docs
- slack
- docs
- connections
- src/airflow/providers/slack
- hooks
- operators
- tests/unit/slack
- hooks
- operators
- smtp
- docs
- src/airflow/providers/smtp
- hooks
- tests/unit/smtp/hooks
- snowflake
- docs
- connections
- operators
- src/airflow/providers/snowflake
- hooks
- operators
- tests/unit/snowflake/hooks
- sqlite
- docs
- connections
- src/airflow/providers/sqlite
- tests/unit/sqlite/hooks
- ssh
- docs
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 | |
|---|---|---|---|
| |||
65 | 65 | | |
66 | 66 | | |
67 | 67 | | |
| 68 | + | |
| 69 | + | |
68 | 70 | | |
69 | 71 | | |
70 | 72 | | |
| |||
169 | 171 | | |
170 | 172 | | |
171 | 173 | | |
| 174 | + | |
172 | 175 | | |
173 | 176 | | |
174 | 177 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| 7 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
7 | 10 | | |
8 | 11 | | |
9 | 12 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
5 | 5 | | |
6 | 6 | | |
7 | 7 | | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
8 | 11 | | |
9 | 12 | | |
10 | 13 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
5 | 5 | | |
6 | 6 | | |
7 | 7 | | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
8 | 11 | | |
9 | 12 | | |
10 | 13 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
85 | 85 | | |
86 | 86 | | |
87 | 87 | | |
| 88 | + | |
88 | 89 | | |
89 | 90 | | |
90 | 91 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
12 | 12 | | |
13 | 13 | | |
14 | 14 | | |
15 | | - | |
| 15 | + | |
| 16 | + | |
16 | 17 | | |
17 | 18 | | |
18 | | - | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
19 | 23 | | |
20 | 24 | | |
21 | 25 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
16 | | - | |
| 16 | + | |
17 | 17 | | |
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
23 | 23 | | |
24 | | - | |
| 24 | + | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
| 56 | + | |
56 | 57 | | |
57 | 58 | | |
58 | 59 | | |
| |||
61 | 62 | | |
62 | 63 | | |
63 | 64 | | |
64 | | - | |
65 | | - | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
66 | 69 | | |
67 | 70 | | |
68 | 71 | | |
| |||
88 | 91 | | |
89 | 92 | | |
90 | 93 | | |
| 94 | + | |
91 | 95 | | |
92 | 96 | | |
93 | 97 | | |
94 | 98 | | |
95 | 99 | | |
| 100 | + | |
96 | 101 | | |
97 | 102 | | |
98 | 103 | | |
99 | 104 | | |
100 | 105 | | |
101 | 106 | | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
| 116 | + | |
| 117 | + | |
102 | 118 | | |
103 | 119 | | |
104 | | - | |
| 120 | + | |
105 | 121 | | |
106 | 122 | | |
107 | 123 | | |
108 | 124 | | |
109 | | - | |
110 | | - | |
111 | | - | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
112 | 128 | | |
113 | 129 | | |
114 | | - | |
| 130 | + | |
115 | 131 | | |
116 | 132 | | |
117 | 133 | | |
118 | 134 | | |
119 | 135 | | |
120 | | - | |
| 136 | + | |
121 | 137 | | |
122 | 138 | | |
123 | 139 | | |
| |||
142 | 158 | | |
143 | 159 | | |
144 | 160 | | |
145 | | - | |
| 161 | + | |
146 | 162 | | |
147 | 163 | | |
148 | 164 | | |
| 165 | + | |
| 166 | + | |
| 167 | + | |
| 168 | + | |
| 169 | + | |
| 170 | + | |
| 171 | + | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
41 | | - | |
| 41 | + | |
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
54 | 54 | | |
55 | 55 | | |
56 | 56 | | |
| 57 | + | |
57 | 58 | | |
58 | 59 | | |
59 | 60 | | |
| |||
78 | 79 | | |
79 | 80 | | |
80 | 81 | | |
| 82 | + | |
81 | 83 | | |
82 | 84 | | |
83 | 85 | | |
| |||
0 commit comments