Commit 38887f1
File tree
- .github
- ISSUE_TEMPLATE
- actions
- breeze
- install-prek
- post_tests_failure
- post_tests_success
- workflows
- airflow-core
- docs
- administration-and-deployment
- logging-monitoring
- authoring-and-scheduling
- core-concepts
- auth-manager
- executor
- howto
- docker-compose
- img
- installation
- security
- tutorial
- newsfragments
- src/airflow
- api_fastapi
- auth
- managers
- simple
- routes
- ui
- openapi-gen
- queries
- requests
- src/queries
- middlewares
- common
- core_api
- datamodels
- ui
- openapi
- routes
- public
- ui
- services
- public
- ui
- execution_api
- datamodels
- routes
- versions
- api/common
- assets
- callbacks
- cli
- commands
- config_templates
- dag_processing
- bundles
- importers
- example_dags/plugins
- executors
- jobs
- lineage
- listeners
- spec
- logging
- migrations/versions
- models
- observability
- metrics
- partition_mapper
- secrets
- serialization
- definitions
- task
- ti_deps/deps
- timetables
- ui
- openapi-gen
- queries
- requests
- public/i18n
- locales
- ar
- ca
- de
- en
- es
- fr
- he
- ko
- nl
- pl
- tr
- zh-CN
- zh-TW
- rules
- src
- components
- ActionAccordion
- Assets
- Clear
- Run
- TaskInstance
- DagActions
- DataTable
- FilterBar
- filters
- FlexibleForm
- Graph
- MarkAs
- Run
- TaskInstance
- SearchDags
- TriggerDag
- ui
- Pagination
- Select
- context
- hover
- openGroups
- timezone
- hooks
- layouts
- Details
- Gantt
- Graph
- Grid
- mocks/handlers
- pages
- AssetsList
- Asset
- Configs
- Connections
- DagsList
- DagsFilters
- Dag
- Backfills
- Calendar
- Code
- Overview
- Tasks
- TaskFilters
- Dashboard
- Health
- PoolSummary
- Events
- GroupTaskInstance
- HITLTaskInstances
- Pools
- Run
- TaskInstances
- TaskInstance
- Logs
- Variables
- ManageVariable
- XCom
- queries
- utils
- tests/e2e
- pages
- specs
- utils
- log
- tests
- integration/otel
- unit
- always
- api_fastapi
- auth
- managers
- simple
- middlewares
- common
- core_api
- routes
- public
- ui
- execution_api/versions
- head
- v2025_04_28
- assets
- callbacks
- cli
- commands
- core
- dag_processing
- bundles
- importers
- dags
- executors
- jobs
- listeners
- migrations
- models
- plugins
- serialization
- ti_deps/deps
- timetables
- utils
- log
- airflow-ctl-tests
- tests/airflowctl_tests
- airflow-ctl
- docs
- images
- src/airflowctl
- api
- datamodels
- ctl
- tests/airflow_ctl
- api
- ctl
- commands
- airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests
- chart
- docs
- files
- newsfragments
- templates
- api-server
- cleanup
- configmaps
- dag-processor
- database-cleanup
- flower
- jobs
- pgbouncer
- rbac
- scheduler
- statsd
- triggerer
- webserver
- workers
- clients/python
- contributing-docs
- mprocs
- quick-start-ide
- testing
- devel-common
- src
- docs/utils
- sphinx_exts
- templates
- tests_common
- test_utils
- dev
- backport
- breeze
- doc
- ci
- images
- src/airflow_breeze
- commands
- params
- utils
- tests
- ide_setup
- react-plugin-tools/react_plugin_template
- src
- stats
- docker-stack-docs
- docs
- generated
- go-sdk
- bundle/bundlev1/bundlev1server/impl
- helm-tests/tests
- chart_utils
- helm_tests
- airflow_aux
- airflow_core
- apiserver
- other
- security
- webserver
- kubernetes-tests/tests/kubernetes_tests
- providers-summary-docs
- core-extensions
- howto
- providers
- airbyte
- docs
- src/airflow/providers/airbyte
- alibaba
- docs
- src/airflow/providers/alibaba
- cloud/links
- amazon
- docs
- operators
- src/airflow/providers/amazon
- aws
- auth_manager
- avp
- cli
- routes
- cli
- executors
- aws_lambda
- batch
- ecs
- hooks
- links
- log
- operators
- queues
- secrets
- sensors
- transfers
- triggers
- tests
- system/amazon/aws
- tests
- unit/amazon/aws
- cli
- executors
- aws_lambda
- batch
- ecs
- hooks
- log
- operators
- sensors
- transfers
- triggers
- apache
- beam
- docs
- src/airflow/providers/apache/beam
- hooks
- operators
- triggers
- cassandra
- docs
- src/airflow/providers/apache/cassandra
- drill
- docs
- src/airflow/providers/apache/drill
- druid
- docs
- src/airflow/providers/apache/druid
- tests/unit/apache/druid/operators
- flink
- docs
- src/airflow/providers/apache/flink
- hdfs
- docs
- src/airflow/providers/apache/hdfs
- hive
- docs
- src/airflow/providers/apache/hive
- hooks
- plugins
- iceberg
- docs
- src/airflow/providers/apache/iceberg
- impala
- docs
- src/airflow/providers/apache/impala
- hooks
- kafka
- docs
- src/airflow/providers/apache/kafka
- hooks
- kylin
- docs
- src/airflow/providers/apache/kylin
- livy
- docs
- src/airflow/providers/apache/livy
- hooks
- tests/unit/apache/livy/hooks
- pig
- docs
- src/airflow/providers/apache/pig
- pinot
- docs
- src/airflow/providers/apache/pinot
- spark
- docs
- decorators
- src/airflow/providers/apache/spark
- decorators
- operators
- tests
- system/apache/spark
- unit/apache/spark
- decorators
- operators
- 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
- cli
- executors
- tests
- integration/celery
- unit/celery
- cli
- executors
- cloudant
- docs
- src/airflow/providers/cloudant
- cncf/kubernetes
- docs
- src/airflow/providers/cncf/kubernetes
- cli
- executors
- hooks
- operators
- triggers
- utils
- tests/unit/cncf/kubernetes
- cli
- decorators
- executors
- hooks
- operators
- utils
- cohere
- docs
- src/airflow/providers/cohere
- common
- compat
- docs
- src/airflow/providers/common/compat
- lineage
- openlineage
- standard
- tests/unit/common/compat
- lineage
- openlineage
- io
- docs
- src/airflow/providers/common/io
- xcom
- tests/unit/common/io/xcom
- messaging
- docs
- src/airflow/providers/common/messaging
- sql
- docs
- src/airflow/providers/common/sql
- hooks
- tests/unit/common/sql/hooks
- databricks
- docs
- src/airflow/providers/databricks
- hooks
- operators
- plugins
- tests/unit/databricks
- hooks
- operators
- plugins
- utils
- datadog
- docs
- src/airflow/providers/datadog
- dbt/cloud
- docs
- src/airflow/providers/dbt/cloud
- hooks
- tests/unit/dbt/cloud
- hooks
- operators
- utils
- dingding
- docs
- src/airflow/providers/dingding
- discord
- docs
- src/airflow/providers/discord
- docker
- docs
- src/airflow/providers/docker
- tests/unit/docker
- decorators
- operators
- edge3
- docs
- src/airflow/providers/edge3
- cli
- executors
- models
- plugins
- templates
- www
- dist
- src
- layouts
- worker_api
- routes
- tests/unit/edge3
- cli
- plugins
- worker_api/routes
- elasticsearch
- docs
- src/airflow/providers/elasticsearch
- log
- tests/unit/elasticsearch/log
- exasol
- docs
- src/airflow/providers/exasol
- hooks
- fab
- 3rd-party-licenses
- docs
- auth-manager
- img
- src/airflow/providers/fab
- auth_manager
- api_endpoints
- api_fastapi
- datamodels
- openapi
- routes
- services
- cli_commands
- models
- security_manager
- views
- cli
- www
- extensions
- static
- dist
- js
- templates/airflow
- tests/unit/fab
- auth_manager
- api_fastapi
- datamodels
- routes
- services
- cli_commands
- cli
- views
- cli
- plugins
- facebook
- docs
- src/airflow/providers/facebook
- ftp
- docs
- src/airflow/providers/ftp
- github
- docs
- connections
- src/airflow/providers/github
- hooks
- tests/unit/github
- hooks
- operators
- sensors
- git
- docs
- src/airflow/providers/git
- google
- docs
- message-queues
- operators/cloud
- src/airflow/providers/google
- 3rd-party-licenses
- cloud
- hooks
- links
- operators
- secrets
- transfers
- triggers
- utils
- common/hooks
- event_scheduling
- events
- leveldb/hooks
- marketing_platform/links
- tests
- system/google
- cloud
- dataflow
- gen_ai
- resources
- vertex_ai
- event_scheduling
- leveldb
- unit/google
- cloud
- hooks
- links
- operators
- transfers
- triggers
- utils
- event_scheduling
- events
- leveldb
- hooks
- operators
- marketing_platform/operators
- grpc
- docs
- src/airflow/providers/grpc
- hashicorp
- docs
- src/airflow/providers/hashicorp
- _internal_client
- secrets
- tests/unit/hashicorp/secrets
- http
- docs
- src/airflow/providers/http
- hooks
- operators
- sensors
- tests/unit/http/sensors
- imap
- docs
- src/airflow/providers/imap
- influxdb
- docs
- src/airflow/providers/influxdb
- jdbc
- docs
- src/airflow/providers/jdbc
- jenkins
- docs
- src/airflow/providers/jenkins
- keycloak
- docs
- auth-manager
- manage
- src/airflow/providers/keycloak
- auth_manager
- cli
- datamodels
- openapi
- routes
- services
- cli
- tests/unit/keycloak
- auth_manager
- cli
- routes
- services
- cli
- microsoft
- azure
- docs
- src/airflow/providers/microsoft/azure
- hooks
- log
- operators
- secrets
- sensors
- triggers
- tests/unit/microsoft/azure
- hooks
- triggers
- mssql
- docs
- src/airflow/providers/microsoft/mssql
- tests/unit/microsoft/mssql/hooks
- psrp
- docs
- src/airflow/providers/microsoft/psrp
- winrm
- docs
- src/airflow/providers/microsoft/winrm
- operators
- mongo
- docs
- src/airflow/providers/mongo
- mysql
- docs
- src/airflow/providers/mysql
- hooks
- tests/unit/mysql/hooks
- neo4j
- docs
- src/airflow/providers/neo4j
- odbc
- docs
- src/airflow/providers/odbc
- hooks
- openai
- docs
- src/airflow/providers/openai
- openfaas
- docs
- src/airflow/providers/openfaas
- openlineage
- docs
- guides
- src/airflow/providers/openlineage
- plugins
- utils
- tests
- system/openlineage
- unit/openlineage
- extractors
- 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
- hooks
- tests/unit/oracle
- hooks
- pagerduty
- docs
- src/airflow/providers/pagerduty
- hooks
- papermill
- docs
- src/airflow/providers/papermill
- pgvector
- docs
- src/airflow/providers/pgvector
- pinecone
- docs
- src/airflow/providers/pinecone
- postgres
- docs
- src/airflow/providers/postgres
- hooks
- tests/unit/postgres/hooks
- presto
- docs
- src/airflow/providers/presto
- hooks
- 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
- filesystems
- sensors
- src/airflow/providers/sftp
- fs
- hooks
- sensors
- tests/unit/sftp
- fs
- hooks
- singularity
- docs
- src/airflow/providers/singularity
- slack
- docs
- src/airflow/providers/slack
- tests/unit/slack/transfers
- smtp
- docs
- src/airflow/providers/smtp
- snowflake
- docs
- src/airflow/providers/snowflake
- hooks
- tests/unit/snowflake
- hooks
- utils
- sqlite
- docs
- src/airflow/providers/sqlite
- ssh
- docs
- operators
- src/airflow/providers/ssh
- hooks
- operators
- triggers
- utils
- tests/unit/ssh
- hooks
- operators
- triggers
- utils
- standard
- docs
- operators
- src/airflow/providers/standard
- example_dags
- operators
- sensors
- triggers
- utils
- tests/unit/standard
- decorators
- operators
- sensors
- utils
- tableau
- docs
- src/airflow/providers/tableau
- telegram
- docs
- src/airflow/providers/telegram
- teradata
- docs
- src/airflow/providers/teradata
- hooks
- transfers
- trino
- docs
- src/airflow/providers/trino
- hooks
- vertica
- docs
- src/airflow/providers/vertica
- hooks
- weaviate
- docs
- src/airflow/providers/weaviate
- yandex
- docs
- src/airflow/providers/yandex
- links
- secrets
- tests/unit/yandex/utils
- ydb
- docs
- src/airflow/providers/ydb
- zendesk
- docs
- src/airflow/providers/zendesk
- scripts
- ci
- docker-compose
- prek
- docker
- in_container
- bin
- tools
- task-sdk
- docs
- src/airflow/sdk
- api/datamodels
- bases
- definitions
- _internal
- asset
- decorators
- partition_mapper
- timetables
- execution_time
- secrets
- io
- observability/metrics
- serde
- serializers
- tests
- task_sdk
- bases
- definitions
- docs
- execution_time
- io
- serde
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 | |
|---|---|---|---|
| |||
15 | 15 | | |
16 | 16 | | |
17 | 17 | | |
| 18 | + | |
18 | 19 | | |
19 | 20 | | |
20 | 21 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
9 | 9 | | |
10 | 10 | | |
11 | 11 | | |
12 | | - | |
13 | | - | |
14 | | - | |
15 | 12 | | |
16 | | - | |
| 13 | + | |
17 | 14 | | |
18 | 15 | | |
19 | 16 | | |
20 | 17 | | |
21 | 18 | | |
22 | 19 | | |
23 | | - | |
| 20 | + | |
24 | 21 | | |
25 | 22 | | |
26 | 23 | | |
| |||
33 | 30 | | |
34 | 31 | | |
35 | 32 | | |
36 | | - | |
| 33 | + | |
37 | 34 | | |
38 | 35 | | |
39 | | - | |
| 36 | + | |
40 | 37 | | |
41 | 38 | | |
42 | 39 | | |
43 | 40 | | |
44 | 41 | | |
45 | | - | |
| 42 | + | |
46 | 43 | | |
47 | 44 | | |
48 | 45 | | |
| |||
51 | 48 | | |
52 | 49 | | |
53 | 50 | | |
54 | | - | |
55 | | - | |
| 51 | + | |
| 52 | + | |
56 | 53 | | |
57 | 54 | | |
58 | 55 | | |
| |||
87 | 84 | | |
88 | 85 | | |
89 | 86 | | |
90 | | - | |
91 | | - | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
92 | 90 | | |
93 | 91 | | |
94 | | - | |
| 92 | + | |
95 | 93 | | |
| 94 | + | |
96 | 95 | | |
97 | 96 | | |
| 97 | + | |
98 | 98 | | |
99 | 99 | | |
100 | 100 | | |
101 | | - | |
102 | 101 | | |
103 | 102 | | |
104 | 103 | | |
| |||
115 | 114 | | |
116 | 115 | | |
117 | 116 | | |
118 | | - | |
| 117 | + | |
119 | 118 | | |
120 | 119 | | |
121 | | - | |
| 120 | + | |
122 | 121 | | |
123 | 122 | | |
124 | 123 | | |
| |||
| 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 | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
3 | | - | |
4 | | - | |
5 | | - | |
6 | | - | |
7 | | - | |
8 | | - | |
9 | | - | |
10 | | - | |
11 | | - | |
12 | | - | |
13 | | - | |
14 | | - | |
15 | | - | |
16 | | - | |
17 | | - | |
18 | | - | |
| 2 | + | |
19 | 3 | | |
20 | | - | |
21 | | - | |
22 | | - | |
23 | | - | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
24 | 9 | | |
25 | | - | |
| 10 | + | |
| 11 | + | |
26 | 12 | | |
27 | 13 | | |
28 | 14 | | |
29 | | - | |
30 | | - | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
31 | 22 | | |
32 | | - | |
33 | | - | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
34 | 26 | | |
35 | 27 | | |
| 28 | + | |
36 | 29 | | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
37 | 33 | | |
38 | | - | |
39 | 34 | | |
40 | | - | |
41 | | - | |
42 | | - | |
43 | | - | |
44 | | - | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
| |||
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | | - | |
| 36 | + | |
37 | 37 | | |
38 | 38 | | |
39 | 39 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
24 | 24 | | |
25 | 25 | | |
26 | 26 | | |
27 | | - | |
| 27 | + | |
28 | 28 | | |
29 | 29 | | |
30 | | - | |
| 30 | + | |
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
| 25 | + | |
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | 29 | | |
30 | 30 | | |
31 | 31 | | |
32 | | - | |
| 32 | + | |
33 | 33 | | |
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
37 | 37 | | |
38 | 38 | | |
39 | | - | |
| 39 | + | |
40 | 40 | | |
41 | 41 | | |
42 | 42 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
34 | | - | |
| 34 | + | |
35 | 35 | | |
36 | 36 | | |
37 | 37 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
311 | 311 | | |
312 | 312 | | |
313 | 313 | | |
314 | | - | |
| 314 | + | |
| 315 | + | |
| 316 | + | |
| 317 | + | |
| 318 | + | |
| 319 | + | |
| 320 | + | |
315 | 321 | | |
316 | 322 | | |
317 | 323 | | |
| |||
436 | 442 | | |
437 | 443 | | |
438 | 444 | | |
439 | | - | |
440 | | - | |
| 445 | + | |
| 446 | + | |
441 | 447 | | |
442 | 448 | | |
443 | 449 | | |
| |||
513 | 519 | | |
514 | 520 | | |
515 | 521 | | |
| 522 | + | |
516 | 523 | | |
517 | 524 | | |
518 | 525 | | |
| |||
521 | 528 | | |
522 | 529 | | |
523 | 530 | | |
| 531 | + | |
| 532 | + | |
| 533 | + | |
| 534 | + | |
| 535 | + | |
| 536 | + | |
| 537 | + | |
| 538 | + | |
| 539 | + | |
| 540 | + | |
| 541 | + | |
| 542 | + | |
524 | 543 | | |
525 | 544 | | |
526 | 545 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
113 | 113 | | |
114 | 114 | | |
115 | 115 | | |
116 | | - | |
| 116 | + | |
117 | 117 | | |
118 | 118 | | |
119 | 119 | | |
| |||
0 commit comments