File tree
1,536 files changed
+27030
-13364
lines changed- .github
- ISSUE_TEMPLATE
- actions
- breeze
- install-pre-commit
- prepare_all_ci_images
- workflows
- airflow-core
- docs
- administration-and-deployment
- logging-monitoring
- authoring-and-scheduling
- howto
- docker-compose
- img
- installation
- src/airflow
- api_fastapi
- auth
- managers/simple/ui
- common
- core_api
- datamodels
- ui
- openapi
- routes
- public
- ui
- services/ui
- execution_api
- datamodels
- versions
- callbacks
- cli
- commands
- config_templates
- dag_processing
- example_dags
- executors
- io
- jobs
- lineage
- metrics
- migrations/versions
- models
- sensors
- serialization
- serializers
- timetables
- traces
- triggers
- ui
- openapi-gen
- queries
- requests
- public/i18n
- locales
- ar
- de
- en
- fr
- he
- ko
- nl
- pl
- zh-TW
- rules
- src
- components
- Clear/TaskInstance
- FlexibleForm
- MarkAs/TaskInstance
- i18n
- locales
- ar
- ko
- layouts
- Details
- Grid
- pages
- Connections
- DagsList
- DagsFilters
- Dag/Overview
- TaskInstance/Logs
- Task
- queries
- utils
- utils
- log
- tests/unit
- always
- api_fastapi
- common
- core_api/routes
- public
- ui
- execution_api/versions/head
- cli/commands
- cluster_policies
- core
- dag_processing
- datasets
- jobs
- listeners
- models
- plugins
- serialization
- serializers
- utils
- log
- airflow-ctl
- docs
- images
- installation
- src/airflowctl
- api
- datamodels
- ctl
- commands
- utils
- tests/airflow_ctl
- api
- ctl/commands
- chart
- docs
- files
- templates
- configmaps
- secrets
- clients/python
- constraints
- contributing-docs
- quick-start-ide
- testing
- devel-common
- sphinx_design/static
- src
- docs
- sphinx_exts
- tests_common
- _internals
- test_utils
- perf/perf_kit
- dev
- airflow_mypy/plugin
- breeze
- doc
- adr
- ci
- images
- src/airflow_breeze
- commands
- params
- prepare_providers
- utils
- tests
- i18n
- docker-stack-docs
- docker-examples
- customizing
- restricted
- docker-tests
- tests/docker_tests
- docs
- generated
- go-sdk
- helm-tests
- tests/helm_tests
- airflow_aux
- airflow_core
- apiserver
- kubernetes-tests
- tests/kubernetes_tests
- performance/src/performance_dags/performance_dag
- providers-summary-docs
- providers
- airbyte
- src/airflow/providers/airbyte
- operators
- sensors
- tests/unit/airbyte
- hooks
- operators
- sensors
- triggers
- alibaba
- src/airflow/providers/alibaba/cloud
- hooks
- links
- operators
- sensors
- tests
- system/alibaba
- unit/alibaba/cloud
- links
- operators
- utils
- amazon
- docs/executors
- src/airflow/providers/amazon/aws
- executors
- batch
- ecs
- utils
- fs
- hooks
- operators
- sensors
- transfers
- triggers
- utils
- waiters
- tests
- system/amazon/aws
- tests
- utils
- unit/amazon/aws
- auth_manager
- cli
- routes
- executors
- batch
- ecs
- hooks
- links
- notifications
- sensors
- transfers
- triggers
- utils
- waiters
- apache
- beam
- docs
- src/airflow/providers/apache/beam
- hooks
- operators
- tests/unit/apache/beam
- hooks
- operators
- cassandra
- src/airflow/providers/apache/cassandra
- hooks
- sensors
- tests/integration/apache/cassandra/hooks
- drill
- druid
- src/airflow/providers/apache/druid
- operators
- transfers
- flink
- src/airflow/providers/apache/flink
- operators
- sensors
- tests/unit/apache/flink
- operators
- sensors
- hdfs
- src/airflow/providers/apache/hdfs
- hooks
- log
- sensors
- hive
- src/airflow/providers/apache/hive
- hooks
- operators
- sensors
- transfers
- tests/unit/apache/hive
- sensors
- transfers
- iceberg
- tests/unit/apache/iceberg/hooks
- impala
- src/airflow/providers/apache/impala
- kafka
- src/airflow/providers/apache/kafka
- operators
- sensors
- tests
- integration/apache/kafka
- hooks
- operators
- triggers
- system/apache/kafka
- unit/apache/kafka
- hooks
- operators
- sensors
- triggers
- kylin
- src/airflow/providers/apache/kylin
- operators
- livy
- src/airflow/providers/apache/livy
- hooks
- operators
- sensors
- triggers
- tests/unit/apache/livy
- hooks
- operators
- sensors
- pig
- src/airflow/providers/apache/pig
- operators
- pinot
- spark
- src/airflow/providers/apache/spark
- decorators
- operators
- tests
- system/apache/spark
- unit/apache/spark
- decorators
- hooks
- tinkerpop
- src/airflow/providers/apache/tinkerpop
- operators
- tests/integration/apache/tinkerpop/hooks
- apprise
- arangodb
- src/airflow/providers/arangodb
- operators
- sensors
- tests/unit/arangodb
- hooks
- sensors
- asana
- src/airflow/providers/asana
- operators
- tests/unit/asana/operators
- atlassian/jira
- src/airflow/providers/atlassian/jira
- operators
- sensors
- tests/unit/atlassian/jira/operators
- celery
- src/airflow/providers/celery
- executors
- sensors
- tests/unit/celery
- cli
- executors
- cloudant
- src/airflow/providers/cloudant/hooks
- tests/unit/cloudant/hooks
- cncf/kubernetes
- src/airflow/providers/cncf/kubernetes
- decorators
- executors
- operators
- sensors
- utils
- tests/unit/cncf/kubernetes
- cli
- decorators
- executors
- hooks
- operators
- sensors
- cohere
- src/airflow/providers/cohere
- operators
- common
- compat
- src/airflow/providers/common/compat
- standard
- io
- src/airflow/providers/common/io
- operators
- tests
- system/common/io
- unit/common/io/xcom
- messaging
- docs
- src/airflow/providers/common/messaging
- sql
- src/airflow/providers/common/sql
- dialects
- hooks
- operators
- sensors
- tests/unit/common/sql
- hooks
- operators
- databricks
- src/airflow/providers/databricks
- hooks
- operators
- plugins
- sensors
- utils
- tests/unit/databricks
- hooks
- operators
- plugins
- triggers
- utils
- datadog
- src/airflow/providers/datadog
- sensors
- tests/unit/datadog/sensors
- dbt/cloud
- src/airflow/providers/dbt/cloud
- hooks
- operators
- sensors
- tests/unit/dbt/cloud
- hooks
- operators
- sensors
- dingding
- src/airflow/providers/dingding
- operators
- tests/unit/dingding/hooks
- discord
- tests/unit/discord
- hooks
- notifications
- docker
- src/airflow/providers/docker
- decorators
- operators
- tests/unit/docker
- decorators
- operators
- edge3
- docs
- src/airflow/providers/edge3
- cli
- example_dags
- executors
- plugins
- worker_api/routes
- tests/unit/edge3
- cli
- plugins
- elasticsearch
- src/airflow/providers/elasticsearch/log
- tests/unit/elasticsearch/log
- exasol
- src/airflow/providers/exasol/hooks
- tests/unit/exasol/hooks
- fab
- docs
- src/airflow/providers/fab
- auth_manager
- api_fastapi/openapi
- api/auth/backend
- security_manager
- www
- api_connexion
- static
- dist
- tests/unit/fab/auth_manager
- api_endpoints
- api_fastapi
- routes
- services
- api/auth/backend
- cli_commands
- facebook
- ftp
- src/airflow/providers/ftp
- hooks
- sensors
- tests/unit/ftp/hooks
- github
- src/airflow/providers/github
- operators
- sensors
- tests/unit/github
- hooks
- operators
- sensors
- git
- tests/unit/git
- bundles
- hooks
- google
- docs/operators/cloud
- src/airflow/providers/google
- ads
- operators
- transfers
- cloud
- hooks
- vertex_ai
- links
- operators
- vertex_ai
- sensors
- vertex_ai
- transfers
- utils
- common
- auth_backend
- hooks
- firebase/operators
- leveldb/operators
- marketing_platform
- links
- operators
- sensors
- suite
- operators
- sensors
- transfers
- tests
- system/google/cloud
- dataflow
- kubernetes_engine
- translate
- vertex_ai
- unit/google
- cloud
- hooks
- links
- log
- operators
- vertex_ai
- secrets
- transfers
- triggers
- utils
- common
- auth_backend
- hooks
- marketing_platform
- links
- operators
- suite/operators
- grpc
- src/airflow/providers/grpc
- hooks
- operators
- hashicorp
- src/airflow/providers/hashicorp/_internal_client
- tests/unit/hashicorp
- _internal_client
- hooks
- http
- src/airflow/providers/http
- hooks
- operators
- sensors
- triggers
- tests/unit/http
- hooks
- operators
- sensors
- triggers
- imap
- src/airflow/providers/imap
- sensors
- tests/unit/imap/hooks
- influxdb
- src/airflow/providers/influxdb
- operators
- jdbc
- tests/unit/jdbc/hooks
- jenkins
- src/airflow/providers/jenkins
- operators
- sensors
- keycloak
- src/airflow/providers/keycloak/auth_manager
- datamodels
- routes
- tests/unit/keycloak/auth_manager/routes
- microsoft
- azure
- docs
- connections
- logging
- newsfragments
- src/airflow/providers/microsoft/azure
- hooks
- operators
- sensors
- triggers
- tests
- system/microsoft/azure
- unit/microsoft/azure
- hooks
- operators
- sensors
- triggers
- mssql
- psrp
- src/airflow/providers/microsoft/psrp/hooks
- winrm
- tests/unit/microsoft/winrm/hooks
- mongo
- src/airflow/providers/mongo
- hooks
- sensors
- tests/unit/mongo/hooks
- mysql
- src/airflow/providers/mysql
- transfers
- tests/unit/mysql/transfers
- neo4j
- src/airflow/providers/neo4j
- operators
- odbc
- openai
- src/airflow/providers/openai
- operators
- openfaas
- openlineage
- src/airflow/providers/openlineage
- extractors
- plugins
- utils
- tests
- system/openlineage
- unit/openlineage
- extractors
- plugins
- utils
- opensearch
- src/airflow/providers/opensearch
- log
- operators
- tests
- system/opensearch
- unit/opensearch
- hooks
- log
- operators
- opsgenie
- src/airflow/providers/opsgenie
- operators
- tests/unit/opsgenie
- hooks
- notifications
- typing
- oracle
- src/airflow/providers/oracle
- operators
- transfers
- tests/unit/oracle
- hooks
- operators
- pagerduty
- src/airflow/providers/pagerduty/hooks
- tests/unit/pagerduty
- hooks
- notifications
- papermill
- src/airflow/providers/papermill
- operators
- pgvector
- pinecone
- src/airflow/providers/pinecone
- operators
- postgres
- src/airflow/providers/postgres/hooks
- presto
- src/airflow/providers/presto
- transfers
- qdrant
- src/airflow/providers/qdrant
- operators
- redis
- src/airflow/providers/redis/sensors
- tests/unit/redis
- hooks
- log
- salesforce
- src/airflow/providers/salesforce
- hooks
- operators
- samba
- src/airflow/providers/samba
- transfers
- tests/unit/samba/hooks
- segment
- src/airflow/providers/segment
- hooks
- operators
- sendgrid
- src/airflow/providers/sendgrid/utils
- sftp
- src/airflow/providers/sftp
- decorators/sensors
- hooks
- operators
- sensors
- tests/unit/sftp/hooks
- singularity
- src/airflow/providers/singularity
- operators
- slack
- src/airflow/providers/slack
- hooks
- operators
- transfers
- tests/unit/slack
- hooks
- transfers
- smtp
- src/airflow/providers/smtp
- operators
- tests/unit/smtp/hooks
- snowflake
- src/airflow/providers/snowflake
- decorators
- hooks
- operators
- utils
- tests/unit/snowflake
- decorators
- hooks
- operators
- transfers
- utils
- sqlite
- tests/unit/sqlite/hooks
- ssh
- src/airflow/providers/ssh
- operators
- tests/unit/ssh
- hooks
- operators
- standard
- docs/operators
- src/airflow/providers/standard
- decorators
- operators
- sensors
- utils
- tests/unit/standard
- decorators
- operators
- sensors
- triggers
- utils
- tableau
- src/airflow/providers/tableau
- operators
- sensors
- tests/unit/tableau/hooks
- telegram
- src/airflow/providers/telegram
- operators
- tests/unit/telegram
- hooks
- operators
- teradata
- docs/operators
- src/airflow/providers/teradata
- hooks
- operators
- transfers
- utils
- tests/unit/teradata
- hooks
- operators
- utils
- trino
- src/airflow/providers/trino
- transfers
- vertica
- src/airflow/providers/vertica/hooks
- weaviate
- src/airflow/providers/weaviate
- hooks
- operators
- yandex
- src/airflow/providers/yandex
- links
- operators
- tests/unit/yandex
- links
- operators
- ydb
- tests/system/ydb
- zendesk
- tests/unit/zendesk/hooks
- scripts
- ci
- docker-compose
- pre_commit
- testing
- docker
- in_container
- tools
- task-sdk
- docs
- src/airflow/sdk
- api
- bases
- definitions
- asset
- decorators
- execution_time
- tests/task_sdk
- api
- bases
- definitions
- decorators
- docs
- execution_time
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,536 files changed
+27030
-13364
lines changedLines changed: 28 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + |
Lines changed: 8 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
37 | 37 |
| |
38 | 38 |
| |
39 | 39 |
| |
40 |
| - | |
41 |
| - | |
42 |
| - | |
43 |
| - | |
44 |
| - | |
45 |
| - | |
46 |
| - | |
47 |
| - | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
48 | 48 |
| |
49 | 49 |
| |
50 | 50 |
| |
|
Lines changed: 2 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
28 | 28 |
| |
29 | 29 |
| |
30 | 30 |
| |
31 |
| - | |
| 31 | + | |
| 32 | + | |
32 | 33 |
| |
33 | 34 |
| |
34 | 35 |
| |
|
Lines changed: 3 additions & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
21 | 21 |
| |
22 | 22 |
| |
23 | 23 |
| |
24 |
| - | |
| 24 | + | |
25 | 25 |
| |
26 | 26 |
| |
27 | 27 |
| |
| |||
41 | 41 |
| |
42 | 42 |
| |
43 | 43 |
| |
| 44 | + | |
| 45 | + | |
44 | 46 |
| |
45 | 47 |
| |
46 | 48 |
| |
|
Lines changed: 8 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
21 | 21 |
| |
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 | + | |
| 35 | + | |
| 36 | + | |
34 | 37 |
| |
35 | 38 |
| |
36 | 39 |
| |
| |||
40 | 43 |
| |
41 | 44 |
| |
42 | 45 |
| |
| 46 | + | |
43 | 47 |
| |
44 | 48 |
| |
45 | 49 |
| |
| |||
86 | 90 |
| |
87 | 91 |
| |
88 | 92 |
| |
| 93 | + | |
| 94 | + |
Lines changed: 2 additions & 7 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
34 | 34 |
| |
35 | 35 |
| |
36 | 36 |
| |
37 |
| - | |
| 37 | + | |
38 | 38 |
| |
39 |
| - | |
40 |
| - | |
41 |
| - | |
42 |
| - | |
43 |
| - | |
44 |
| - | |
| 39 | + | |
45 | 40 |
| |
46 | 41 |
| |
47 | 42 |
| |
|
Lines changed: 28 additions & 10 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
332 | 332 |
| |
333 | 333 |
| |
334 | 334 |
| |
| 335 | + | |
| 336 | + | |
| 337 | + | |
| 338 | + | |
| 339 | + | |
| 340 | + | |
| 341 | + | |
| 342 | + | |
| 343 | + | |
| 344 | + | |
| 345 | + | |
| 346 | + | |
| 347 | + | |
| 348 | + | |
| 349 | + | |
| 350 | + | |
| 351 | + | |
| 352 | + | |
335 | 353 |
| |
336 | 354 |
| |
337 | 355 |
| |
| |||
348 | 366 |
| |
349 | 367 |
| |
350 | 368 |
| |
351 |
| - | |
| 369 | + | |
352 | 370 |
| |
353 | 371 |
| |
354 |
| - | |
| 372 | + | |
355 | 373 |
| |
356 | 374 |
| |
357 |
| - | |
| 375 | + | |
358 | 376 |
| |
359 | 377 |
| |
360 |
| - | |
| 378 | + | |
361 | 379 |
| |
362 | 380 |
| |
363 |
| - | |
| 381 | + | |
364 | 382 |
| |
365 | 383 |
| |
366 |
| - | |
| 384 | + | |
367 | 385 |
| |
368 | 386 |
| |
369 |
| - | |
| 387 | + | |
370 | 388 |
| |
371 | 389 |
| |
372 |
| - | |
| 390 | + | |
373 | 391 |
| |
374 | 392 |
| |
375 |
| - | |
| 393 | + | |
376 | 394 |
| |
377 | 395 |
| |
378 |
| - | |
| 396 | + | |
379 | 397 |
| |
380 | 398 |
| |
381 | 399 |
| |
|
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
135 | 135 |
| |
136 | 136 |
| |
137 | 137 |
| |
138 |
| - | |
| 138 | + | |
139 | 139 |
| |
140 | 140 |
| |
141 | 141 |
| |
|
Lines changed: 2 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
107 | 107 |
| |
108 | 108 |
| |
109 | 109 |
| |
110 |
| - | |
| 110 | + | |
111 | 111 |
| |
112 | 112 |
| |
113 | 113 |
| |
| |||
144 | 144 |
| |
145 | 145 |
| |
146 | 146 |
| |
147 |
| - | |
| 147 | + | |
148 | 148 |
| |
149 | 149 |
| |
150 | 150 |
| |
|
Lines changed: 7 additions & 2 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
61 | 61 |
| |
62 | 62 |
| |
63 | 63 |
| |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
64 | 69 |
| |
65 | 70 |
| |
66 | 71 |
| |
67 | 72 |
| |
68 |
| - | |
| 73 | + | |
69 | 74 |
| |
70 | 75 |
| |
71 | 76 |
| |
| |||
84 | 89 |
| |
85 | 90 |
| |
86 | 91 |
| |
87 |
| - | |
| 92 | + | |
88 | 93 |
| |
89 | 94 |
| |
90 | 95 |
| |
|
0 commit comments