You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by el...@apache.org on 2022/08/01 18:42:27 UTC
[airflow] branch dependabot/npm_and_yarn/airflow/www/terser-5.14.2 updated (03316b808e -> a46ff07529)
This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a change to branch dependabot/npm_and_yarn/airflow/www/terser-5.14.2
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 03316b808e Bump terser from 5.10.0 to 5.14.2 in /airflow/www
add 38d6c28f9c Generate typescript types from rest API docs (#25123)
add de6938e173 No grid auto-refresh for backfill dag runs (#25042)
add a20de275c3 Update index.rst (#25184)
add f0112458e7 Prefix the dags in dataset example dags with example_dataset_ (#25181)
add acff129688 Move javascript compilation to host (#25169)
add 48eb18e031 Add revisionHistoryLimit to all deployments (#25059)
add c3763f3be5 Fix asset compilation via setup.py (#25201)
add 8c872462c5 Add ts types generation to static checks (#25167)
add 88b529d5cc Fix missing space for breeze build-image hint command (#25204)
add cff7d9194f Add Tessian to list of companies using Airflow (#25206)
add 911db9fc3f make MsSQL tests runnable on Python 3.8 (#25214)
add 66b3ca1d28 Migrate Google example bigquery_to_mssql to new design AIP-47 (#25174)
add 90a157a64a call updateNodeLabels after expandGroup (#25217)
add 74e624b68b make MsSQL tests runnable on Python 3.8 (2nd) (#25216)
add 6839813bc7 Also compile assets in non-main (#25220)
add 47b72056c4 SQSPublishOperator should allow sending messages to a FIFO Queue (#25171)
add 03a81b66de Show dataset readiness for the next run (#25141)
add 93b7a57cbc Include missing mention of `external_executor_id` in `sql_engine_collation_for_ids` docs (#25197)
add 210ad6408f Dataset details view (#25208)
add f6bda38e20 Convert RDS Export Sample DAG to System Test (AIP-47) (#25205)
add 17ec6dbcfe Stop SLA callbacks gazumping other callbacks and DOS'ing the DagProcessorManager queue (#25147)
add 1cb16d5588 Upgrade to Pip 22.2 (#25218)
add a25f8c36ec Improve ElasticsearchTaskHandler (#21942)
add d561e5d035 Fix order of returned rows in a flaky test_outlets_dataset test (#25231)
add d66e427c4d Sagemaker System Tests - Part 3 of 3 - example_sagemaker_endpoint.py (AIP-47) (#25134)
add be7cb1e837 Common SQLCheckOperators Various Functionality Update (#25164)
add d85cd3db4c Dataset-triggered dag runs should have the right DagRunType (#25237)
add 31705ed309 Add Databricks provider to boring cyborg (#25238)
add df00436569 Unify DbApiHook.run() method with the methods which override it (#23971)
add 109b260920 Add datasets to dag dependencies view (#25175)
add 1aaf206c64 Make tag fetching when preparing providers optional. (#25236)
add f53bd5df2a Protect against the case when emulated Python is used on M1s (#25229)
add ddaf74df9b convert TimeSensorAsync target_time to utc on call time (#25221)
add ceb1658565 Fix BatchOperator links on wait_for_completion = True (#25228)
add eab0167f1b Add test_connection to Azure Batch hook (#25235)
add b815e221e8 Add override method to TaskGroupDecorator (#25160)
add d7777bb910 fix comments (#25245)
add 877dc89004 Implement map() semantic (#25085)
add bb5a8ec88a Add werkzeug limitation until flask-login will handle it (#25270)
add f634361cb7 Remove support for FAB `APP_THEME` (#15277)
add a5cbcb5677 add europcar to list of companies using Airflow (#25279)
add 4b28635b20 Disallow any dag tags longer than 100 char (#25196)
add d7f4ee1786 Fix ExternalTaskSensor not working with dynamic task (#25215)
add 8bd5c8f6b1 Avoid unnecessary error output when checking for emulated environment (#25289)
add af260bd983 Migrate files to ts (#25267)
add 3bc10e90e0 Add URI to dataset event response (#25250)
add 52d11a9fdd Use tables in grid details panes (#25258)
add 722a719769 Rename `created_at` to `timestamp` in DatasetEvent (#25292)
add 1544868b6e Add dev version of asset compilation (#25272)
add 5758454ec3 [docs] Update DAG run to clarify when a DAG actually runs (#25290)
add c8af0592c0 Improve taskflow type hints with ParamSpec (#25173)
add d876b4aa6d add common-sql label to boring-cyborg.yml (#25298)
add b288bf4da4 Delete redundant system test bigquery_to_bigquery (#25261)
add 7438707747 Improved telemetry for Databricks provider (#25115)
add 10c9a3697a Migrate Google example natural_language to new design AIP-47 (#25262)
add 1eb91b953b Adjust heuristics for PR of the Month script (#25239)
add 28db8c10b2 Migrate Google example life_sciences to new design AIP-47 (#25264)
add 432977be0c Resolve and validate AWS Connection parameters in wrapper (#25256)
add 3b9d7d27ff Adds new warning to provider verification (#25310)
add a0aa93f98c Fix too long names of files and docker compose projects (#25301)
add 7e631a9e38 Introduce sla_miss metric (#23402)
add 8bc147192c Fix Flask Login user setting for Flask 2.2 and Flask-Login 0.6.2 (#25318)
add 54a8c4fd2a More improvements in the Databricks operators (#25260)
add 285c23a2f9 Use simple Json in Dataset & DatasetEvent extra field (#25321)
add df388a3d53 Add __repr__ to ParamsDict class (#25305)
add a69095fea1 Filter XCOM by key when calculating map lengths (#24530)
add 20fe314de3 Refactor test DAGs to unclutter example DAGs (#25327)
add 4e50ea4df0 Fix MsSQL failing on long list of providers. (#25338)
add 89af516243 Allow to add extra flags passed to ``pip install`` when building images (#25337)
add 5d4abbd58c Deprecate hql parameters and synchronize DBApiHook method APIs (#25299)
add b653289e68 Upgrade to latest `pip` version 22.2.1 released today (#25348)
add dbbe9ac87e Remove Werkzeug limitation after flask-login was fixed (#25291)
add 7e295b7d99 Add possibility to specify command to run at Breeze entry via env var (#25288)
add b0fd105f4a Allow Legacy SqlSensor to use the common.sql providers (#25293)
add 5efe6f34fd Remove useless logging line (#25347)
add 8b4e55f68f List upstream dataset events (#25300)
add e994f2b020 Add dataset-triggered run type icon (#25244)
add d2df9fe786 Add `operator` and `has_outlet_datasets` to `/grid_data` (#25323)
add a31b04cc1d Remove getTasks from Grid view (#25359)
add 7341e98378 Update operators.rst (#25358)
add 8bb0c4fd32 Add `test_connection` method to AzureContainerInstanceHook (#25362)
add 4dc1778a64 test(hooks/exasol): add test for no resultSet rtn type (#25277)
add a8e4519815 Fix Vertex AI Custom Job training issue (#25367)
add 2e5737df53 Remove extraneous word in installation guide (#25371)
add 82f842ffc5 updated documentation for databricks operator (#24599)
add 83166be401 Remove unnecessary asset compilaton for prod images (#25374)
add 4280b19b5f add downstream events to task instances (#25375)
add 900c81b87a Restore pushing CI image as latest to GHCR.io (#25380)
add c3adf3e65d fix - resolve bash by absolute path (#25331)
add c6d3b48d5d Convert ECS Fargate Sample DAG to System Test (#25316)
add 2071519e74 fix: change disable_verify_ssl behaviour (#25023)
add f4b93cc097 Translate system tests migration (AIP-47) (#25340)
add ad0a4965aa Use newer kubernetes authentication method in internal vault client (#25351)
add f6b48ac6df Memorystore assets & system tests migration (AIP-47) (#25361)
add 4e786e31bc Check expand_kwargs() input type before unmapping (#25355)
add c546d25c94 Change stdout and stderr access mode to append in commands (#25253)
add 9febd7f242 Add missing import in best-practices code example (#25391)
add a61e0c1df7 YandexCloud provider: Support new Yandex SDK features for DataProc (#25158)
add aa6985d43e Fix datasets list page (#25382)
add 5e423f5fc0 Adjust limits when constructing cross-provider dependencies (#25364)
add acab8f52dd Move all "old" SQL operators to common.sql providers (#25350)
add c96cf45a44 Add missing option when pushing latest images to cache :( (#25399)
add 9bc0d88078 Add upstream and downstream to datasets api responses (#25390)
add 85e648f970 Refactor DAG pages to be consistent (#25402)
add 703a48d6eb Reword dag run "upstream events" wording (#25405)
add d21947ef8c Add `uri_pattern` query param to Get `/datasets` endpoint (#25411)
add 3cf7aecc43 Update INTHEWILD.md (#25417)
add b90fc14e0c Implement XComArg.zip(*xcom_args) (#25176)
add 5588c3fe6e Create new databases from the ORM (#24156)
add 40eefd8479 Fix `airflow db reset` when dangling tables exist (#25441)
add a9a8df0749 Making sure serialization tests runs on all example dags (#25447)
add c5878315f3 Fix DAG audit_log route (#25415)
add a46ff07529 Bump terser from 5.10.0 to 5.14.2 in /airflow/www
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (03316b808e)
\
N -- N -- N refs/heads/dependabot/npm_and_yarn/airflow/www/terser-5.14.2 (a46ff07529)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.dockerignore | 8 +-
.github/boring-cyborg.yml | 11 +-
.github/workflows/build-images.yml | 2 +
.github/workflows/ci.yml | 23 +-
.gitignore | 2 +-
.pre-commit-config.yaml | 57 +-
BREEZE.rst | 44 +-
CONTRIBUTING.rst | 33 +-
Dockerfile | 147 +-
Dockerfile.ci | 154 +-
IMAGES.rst | 6 +-
INTHEWILD.md | 3 +
STATIC_CODE_CHECKS.rst | 9 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 9 +-
.../api_connexion/endpoints/dataset_endpoint.py | 30 +-
airflow/api_connexion/openapi/v1.yaml | 75 +-
airflow/api_connexion/schemas/dataset_schema.py | 39 +-
airflow/cli/commands/celery_command.py | 10 +-
airflow/cli/commands/dag_processor_command.py | 5 +-
airflow/cli/commands/kerberos_command.py | 5 +-
airflow/cli/commands/scheduler_command.py | 5 +-
airflow/cli/commands/triggerer_command.py | 5 +-
airflow/cli/commands/webserver_command.py | 5 +-
airflow/config_templates/config.yml | 9 +-
airflow/config_templates/default_airflow.cfg | 6 +-
.../config_templates/default_webserver_config.py | 28 -
airflow/dag_processing/manager.py | 41 +-
airflow/dag_processing/processor.py | 1 +
airflow/decorators/__init__.pyi | 12 +-
airflow/decorators/base.py | 80 +-
airflow/decorators/task_group.py | 3 +
airflow/example_dags/example_datasets.py | 101 +-
airflow/exceptions.py | 12 -
airflow/kubernetes/kube_client.py | 11 +-
.../0080_2_0_2_change_default_pool_slots_to_1.py | 5 +
.../versions/0114_2_4_0_add_dataset_model.py | 12 +-
airflow/models/base.py | 23 +-
airflow/models/dag.py | 49 +-
airflow/models/dagrun.py | 9 +-
airflow/models/dataset.py | 25 +-
airflow/models/expandinput.py | 132 +-
airflow/models/mappedoperator.py | 32 +-
airflow/models/param.py | 3 +
airflow/models/renderedtifields.py | 10 +-
airflow/models/taskinstance.py | 20 +-
airflow/models/taskreschedule.py | 14 +-
airflow/models/xcom.py | 14 +-
airflow/models/xcom_arg.py | 448 ++-
airflow/operators/bash.py | 4 +-
airflow/operators/check_operator.py | 24 +-
airflow/operators/druid_check_operator.py | 4 +-
airflow/operators/presto_check_operator.py | 24 +-
airflow/operators/sql.py | 560 +--
airflow/operators/sql_branch_operator.py | 12 +-
.../amazon/aws/example_dags/example_ecs_fargate.py | 62 -
.../amazon/aws/example_dags/example_rds_export.py | 71 -
.../aws/example_dags/example_sagemaker_endpoint.py | 230 --
airflow/providers/amazon/aws/hooks/base_aws.py | 320 +-
airflow/providers/amazon/aws/hooks/sqs.py | 19 +-
airflow/providers/amazon/aws/operators/batch.py | 2 +-
airflow/providers/amazon/aws/operators/ecs.py | 7 +-
airflow/providers/amazon/aws/operators/rds.py | 94 +-
.../providers/amazon/aws/operators/redshift_sql.py | 4 +-
airflow/providers/amazon/aws/operators/sqs.py | 13 +-
.../amazon/aws/transfers/redshift_to_s3.py | 2 +-
.../amazon/aws/transfers/s3_to_redshift.py | 4 +-
.../amazon/aws/utils/connection_wrapper.py | 282 ++
airflow/providers/apache/drill/operators/drill.py | 8 +-
airflow/providers/apache/drill/provider.yaml | 1 -
.../apache/druid/operators/druid_check.py | 6 +-
airflow/providers/apache/druid/provider.yaml | 2 +-
airflow/providers/apache/hive/CHANGELOG.rst | 11 +
airflow/providers/apache/hive/hooks/hive.py | 45 +-
.../providers/apache/hive/operators/hive_stats.py | 2 +-
.../apache/hive/transfers/hive_to_mysql.py | 2 +-
.../apache/hive/transfers/hive_to_samba.py | 2 +-
airflow/providers/apache/pinot/hooks/pinot.py | 10 +-
.../cncf/kubernetes/operators/kubernetes_pod.py | 2 +-
airflow/providers/common/sql/CHANGELOG.rst | 10 +
airflow/providers/common/sql/hooks/sql.py | 95 +-
airflow/providers/common/sql/operators/sql.py | 628 ++-
airflow/providers/common/sql/provider.yaml | 5 +-
airflow/providers/databricks/hooks/databricks.py | 3 +-
.../providers/databricks/hooks/databricks_base.py | 34 +-
.../providers/databricks/hooks/databricks_sql.py | 83 +-
.../providers/databricks/operators/databricks.py | 100 +-
.../databricks/operators/databricks_repos.py | 44 +-
.../databricks/operators/databricks_sql.py | 29 +-
airflow/providers/dbt/cloud/hooks/dbt.py | 2 +-
.../elasticsearch/log/es_json_formatter.py | 48 +
.../providers/elasticsearch/log/es_task_handler.py | 45 +-
airflow/providers/exasol/hooks/exasol.py | 65 +-
airflow/providers/exasol/operators/exasol.py | 6 +-
.../example_dags/example_bigquery_to_bigquery.py | 69 -
.../google/cloud/hooks/cloud_memorystore.py | 6 +-
airflow/providers/google/cloud/hooks/cloud_sql.py | 61 +-
.../google/cloud/hooks/vertex_ai/custom_job.py | 35 +-
.../google/cloud/links/cloud_memorystore.py | 119 +
.../providers/google/cloud/operators/bigquery.py | 8 +-
.../google/cloud/operators/cloud_memorystore.py | 134 +-
.../providers/google/cloud/operators/cloud_sql.py | 6 +-
airflow/providers/google/cloud/operators/gcs.py | 28 +-
.../google/cloud/operators/translate_speech.py | 8 +
.../google/cloud/operators/vertex_ai/custom_job.py | 48 +-
.../google/common/auth_backend/google_openid.py | 5 +-
airflow/providers/google/provider.yaml | 6 +-
.../google/suite/transfers/sql_to_sheets.py | 4 +-
.../hashicorp/_internal_client/vault_client.py | 7 +-
airflow/providers/jdbc/operators/jdbc.py | 14 +-
airflow/providers/microsoft/azure/hooks/batch.py | 13 +
.../microsoft/azure/hooks/container_instance.py | 18 +-
.../azure/operators/container_instances.py | 2 +-
.../providers/microsoft/mssql/operators/mssql.py | 4 +-
airflow/providers/mysql/operators/mysql.py | 6 +-
airflow/providers/neo4j/operators/neo4j.py | 2 +-
airflow/providers/oracle/operators/oracle.py | 6 +-
airflow/providers/postgres/operators/postgres.py | 6 +-
airflow/providers/presto/CHANGELOG.rst | 6 +
airflow/providers/presto/hooks/presto.py | 137 +-
airflow/providers/qubole/hooks/qubole.py | 3 +-
airflow/providers/qubole/operators/qubole_check.py | 2 +-
airflow/providers/qubole/provider.yaml | 2 +-
airflow/providers/salesforce/operators/bulk.py | 2 +-
airflow/providers/snowflake/hooks/snowflake.py | 52 +-
airflow/providers/snowflake/operators/snowflake.py | 25 +-
airflow/providers/snowflake/provider.yaml | 2 +-
airflow/providers/sqlite/operators/sqlite.py | 6 +-
airflow/providers/trino/CHANGELOG.rst | 6 +
airflow/providers/trino/hooks/trino.py | 177 +-
airflow/providers/vertica/operators/vertica.py | 4 +-
airflow/providers/yandex/hooks/yandex.py | 4 +-
.../yandex/operators/yandexcloud_dataproc.py | 190 +-
airflow/providers/yandex/provider.yaml | 2 +-
airflow/sensors/external_task.py | 12 +-
airflow/sensors/sql_sensor.py | 2 +-
airflow/sensors/time_sensor.py | 4 +-
airflow/serialization/serialized_objects.py | 121 +-
airflow/typing_compat.py | 32 +-
airflow/utils/db.py | 55 +-
airflow/www/alias-rest-types.js | 201 +
airflow/www/ask_for_recompile_assets_if_needed.sh | 56 -
airflow/www/compile_assets.sh | 34 -
airflow/www/package.json | 6 +-
...strap-theme.css => airflow_bootstrap_theme.css} | 0
airflow/www/static/css/graph.css | 9 +
airflow/www/static/js/api/index.ts | 8 +-
.../static/js/api/{useTasks.ts => useDataset.ts} | 20 +-
airflow/www/static/js/api/useDatasetEvents.ts | 73 +
airflow/www/static/js/api/useDatasets.ts | 6 +-
airflow/www/static/js/api/useGridData.test.js | 30 +-
airflow/www/static/js/api/useGridData.ts | 2 +-
...useMappedInstances.js => useMappedInstances.ts} | 33 +-
airflow/www/static/js/api/useTasks.test.jsx | 86 -
...{useDatasets.ts => useUpstreamDatasetEvents.ts} | 36 +-
airflow/www/static/js/components/RunTypeIcon.tsx | 47 +
airflow/www/static/js/components/Table/Cells.tsx | 61 +
.../js/components/{ => Table}/Table.test.tsx | 63 +-
.../js/components/{Table.tsx => Table/index.tsx} | 30 +-
airflow/www/static/js/components/Time.tsx | 2 +-
airflow/www/static/js/dag/InstanceTooltip.tsx | 2 +-
.../www/static/js/dag/details/{Dag.jsx => Dag.tsx} | 74 +-
airflow/www/static/js/dag/details/Header.tsx | 58 +-
.../js/dag/details/dagRun/UpstreamEvents.tsx | 82 +
airflow/www/static/js/dag/details/dagRun/index.tsx | 162 +-
.../static/js/dag/details/taskInstance/Details.tsx | 122 +-
.../dag/details/taskInstance/DownstreamEvents.tsx | 81 +
.../{MappedInstances.jsx => MappedInstances.tsx} | 48 +-
.../www/static/js/dag/details/taskInstance/Nav.tsx | 2 +-
.../static/js/dag/details/taskInstance/index.tsx | 42 +-
airflow/www/static/js/dag/grid/dagRuns/Bar.tsx | 31 +-
.../js/dag/nav/{FilterBar.jsx => FilterBar.tsx} | 16 +-
.../{useFilters.test.jsx => useFilters.test.tsx} | 34 +-
.../js/dag/{useFilters.js => useFilters.tsx} | 34 +-
airflow/www/static/js/datasets/Details.tsx | 134 +
airflow/www/static/js/datasets/List.tsx | 62 +-
airflow/www/static/js/datasets/index.tsx | 30 +-
airflow/www/static/js/graph.js | 1 +
airflow/www/static/js/types/api-generated.ts | 4177 ++++++++++++++++++++
airflow/www/static/js/types/index.ts | 25 +-
airflow/www/static/js/utils/index.test.ts | 114 +
airflow/www/static/js/utils/index.ts | 68 +
airflow/www/templates/airflow/dag.html | 9 +-
.../www/templates/airflow/dag_dependencies.html | 1 +
airflow/www/templates/airflow/dags.html | 5 +-
airflow/www/templates/airflow/datasets.html | 1 +
airflow/www/templates/airflow/main.html | 6 +-
airflow/www/tsconfig.json | 1 +
airflow/www/views.py | 181 +-
airflow/www/webpack.config.js | 2 +-
airflow/www/yarn.lock | 50 +
breeze-legacy | 8 -
.../dag-processor/dag-processor-deployment.yaml | 4 +
chart/templates/flower/flower-deployment.yaml | 4 +
.../templates/pgbouncer/pgbouncer-deployment.yaml | 4 +
.../templates/scheduler/scheduler-deployment.yaml | 4 +
chart/templates/statsd/statsd-deployment.yaml | 4 +
.../templates/triggerer/triggerer-deployment.yaml | 4 +
.../templates/webserver/webserver-deployment.yaml | 4 +
chart/templates/workers/worker-deployment.yaml | 4 +
chart/values.schema.json | 81 +
chart/values.yaml | 19 +
.../airflow_breeze/commands/ci_image_commands.py | 2 +
.../airflow_breeze/commands/developer_commands.py | 35 +
.../src/airflow_breeze/commands/main_command.py | 75 +
.../commands/production_image_commands.py | 2 +
.../commands/release_management_commands.py | 5 +-
dev/breeze/src/airflow_breeze/global_constants.py | 9 +-
.../src/airflow_breeze/params/build_ci_params.py | 1 +
.../src/airflow_breeze/params/build_prod_params.py | 11 +-
.../airflow_breeze/params/common_build_params.py | 1 +
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 3 +
.../src/airflow_breeze/utils/common_options.py | 6 +
.../airflow_breeze/utils/docker_command_utils.py | 1 +
dev/breeze/src/airflow_breeze/utils/run_utils.py | 39 +
dev/provider_packages/prepare_provider_packages.py | 30 +-
dev/stats/explore_pr_candidates.ipynb | 95 +
dev/stats/get_important_pr_candidates.py | 254 +-
.../operators/ecs.rst | 2 +-
.../operators/rds.rst | 6 +-
.../operators/sagemaker.rst | 6 +-
.../operators/submit_run.rst | 54 +-
.../operators/cloud/cloud_memorystore.rst | 26 +-
.../cloud/cloud_memorystore_memcached.rst | 14 +-
.../operators/cloud/life_sciences.rst | 6 +-
.../operators/cloud/natural_language.rst | 20 +-
.../operators/cloud/translate.rst | 4 +-
.../operators/cloud/translate_speech.rst | 4 +-
docs/apache-airflow-providers-jdbc/operators.rst | 2 +-
docs/apache-airflow-providers-tableau/index.rst | 2 +-
docs/apache-airflow/best-practices.rst | 4 +-
docs/apache-airflow/dag-run.rst | 43 +-
docs/apache-airflow/logging-monitoring/metrics.rst | 1 +
docs/apache-airflow/operators-and-hooks-ref.rst | 6 -
docs/docker-stack/build-arg-ref.rst | 16 +-
docs/docker-stack/changelog.rst | 5 +
docs/spelling_wordlist.txt | 2 +
generated/README.md | 2 +
generated/provider_dependencies.json | 17 +-
images/breeze/output-build-image.svg | 300 +-
images/breeze/output-build-prod-image.svg | 364 +-
images/breeze/output-commands-hash.txt | 7 +-
images/breeze/output-commands.svg | 384 +-
images/breeze/output-compile-www-assets.svg | 115 +
images/breeze/output-static-checks.svg | 232 +-
newsfragments/25147.bugfix.rst | 1 +
scripts/ci/docker-compose/_docker.env | 1 +
scripts/ci/docker-compose/base.yml | 1 +
scripts/ci/docker-compose/devcontainer.env | 1 +
scripts/ci/libraries/_initialization.sh | 30 +-
scripts/ci/libraries/_testing.sh | 2 +-
.../pre_commit_base_operator_partial_arguments.py | 1 -
.../ci/pre_commit/pre_commit_compile_www_assets.py | 25 +-
.../pre_commit_compile_www_assets_dev.py | 25 +-
scripts/ci/pre_commit/pre_commit_ui_lint.py | 40 +-
scripts/ci/pre_commit/pre_commit_www_lint.py | 42 +-
scripts/ci/testing/ci_run_airflow_testing.sh | 6 +-
.../ci_run_single_airflow_test_in_docker.sh | 6 +-
scripts/docker/common.sh | 2 +-
scripts/docker/compile_www_assets.sh | 71 -
scripts/docker/entrypoint_ci.sh | 11 +-
scripts/docker/install_additional_dependencies.sh | 2 +
scripts/docker/install_airflow.sh | 4 +
...install_airflow_dependencies_from_branch_tip.sh | 1 +
.../docker/install_from_docker_context_files.sh | 4 +-
scripts/docker/prepare_node_modules.sh | 52 -
scripts/in_container/_in_container_utils.sh | 24 +-
scripts/in_container/run_init_script.sh | 4 +
.../in_container/run_prepare_airflow_packages.sh | 2 +-
scripts/in_container/run_tmux_welcome.sh | 8 +-
scripts/in_container/verify_providers.py | 5 +
setup.cfg | 2 +-
setup.py | 23 +-
.../endpoints/test_dag_run_endpoint.py | 25 +-
.../endpoints/test_dataset_endpoint.py | 92 +-
tests/api_connexion/schemas/test_dataset_schema.py | 70 +-
tests/charts/test_dag_processor.py | 18 +
tests/charts/test_flower.py | 19 +
tests/charts/test_pgbouncer.py | 18 +
tests/charts/test_scheduler.py | 14 +
tests/charts/test_statsd.py | 15 +
tests/charts/test_triggerer.py | 18 +
tests/charts/test_webserver.py | 14 +
tests/charts/test_worker.py | 14 +
tests/cli/commands/test_celery_command.py | 6 +-
tests/cli/commands/test_kerberos_command.py | 6 +-
tests/conftest.py | 10 +
tests/dag_processing/test_manager.py | 62 +
tests/dag_processing/test_processor.py | 4 +-
tests/dags/test_datasets.py | 89 +
tests/decorators/test_python.py | 7 +-
.../test_task_group.py} | 43 +-
tests/deprecated_classes.py | 18 +-
.../internal_api}/__init__.py | 0
tests/kubernetes/test_client.py | 13 +
tests/models/test_dag.py | 67 +-
tests/models/test_mappedoperator.py | 37 +
tests/models/test_param.py | 4 +
tests/models/test_taskinstance.py | 83 +-
tests/models/test_xcom_arg.py | 44 +
tests/models/test_xcom_arg_map.py | 303 ++
tests/operators/test_sql.py | 779 ----
tests/providers/amazon/aws/hooks/test_base_aws.py | 97 +-
tests/providers/amazon/aws/operators/test_ecs.py | 7 +-
tests/providers/amazon/aws/operators/test_rds.py | 211 +
tests/providers/amazon/aws/operators/test_sqs.py | 33 +
.../amazon/aws/utils/test_connection_wrapper.py | 283 ++
tests/providers/apache/hive/hooks/test_hive.py | 2 +-
.../apache/hive/transfers/test_hive_to_mysql.py | 4 +-
.../apache/hive/transfers/test_hive_to_samba.py | 2 +-
.../apache/hive/transfers/test_mssql_to_hive.py | 16 +-
tests/providers/common/sql/hooks/test_dbapi.py | 20 +
tests/providers/common/sql/operators/test_sql.py | 804 +++-
.../providers/databricks/hooks/test_databricks.py | 54 +-
.../databricks/hooks/test_databricks_sql.py | 11 +-
.../databricks/operators/test_databricks.py | 11 +
.../databricks/operators/test_databricks_repos.py | 30 +-
.../databricks/operators/test_databricks_sql.py | 11 +-
.../elasticsearch/log/test_es_task_handler.py | 10 +-
tests/providers/exasol/hooks/test_exasol.py | 9 +
.../cloud/operators/test_cloud_memorystore.py | 16 +
.../operators/test_cloud_memorystore_system.py | 51 -
.../cloud/operators/test_life_sciences_system.py | 43 -
.../google/cloud/operators/test_translate.py | 3 +-
.../cloud/operators/test_translate_speech.py | 3 +-
.../operators/test_translate_speech_system.py | 41 -
.../cloud/operators/test_translate_system.py | 35 -
.../google/cloud/operators/test_vertex_ai.py | 3 +
.../transfers/test_bigquery_to_bigquery_system.py | 37 -
.../cloud/transfers/test_gdrive_to_gcs_system.py | 2 +-
.../google/cloud/transfers/test_mssql_to_gcs.py | 6 +-
.../_internal_client/test_vault_client.py | 20 +-
tests/providers/hashicorp/hooks/test_vault.py | 18 +-
tests/providers/jdbc/operators/test_jdbc.py | 3 +-
.../microsoft/azure/hooks/test_azure_batch.py | 17 +
.../azure/hooks/test_azure_container_instance.py | 16 +-
.../providers/microsoft/mssql/hooks/test_mssql.py | 8 +-
.../microsoft/mssql/operators/test_mssql.py | 9 +-
tests/providers/oracle/hooks/test_oracle.py | 8 +-
.../qubole/operators/test_qubole_check.py | 14 +-
tests/providers/slack/operators/test_slack.py | 8 +-
.../providers/slack/transfers/test_sql_to_slack.py | 6 +-
tests/providers/yandex/hooks/test_yandex.py | 18 +-
.../yandex/operators/test_yandexcloud_dataproc.py | 5 +
tests/sensors/test_time_sensor.py | 7 +
tests/serialization/test_dag_serialization.py | 34 +-
.../providers/amazon/aws/example_ecs_fargate.py | 144 +
.../providers/amazon/aws/example_rds_export.py | 188 +
.../amazon/aws/example_sagemaker_endpoint.py | 290 ++
.../system/providers/amazon/aws/utils/__init__.py | 23 +-
.../cloud/bigquery}/example_bigquery_to_mssql.py | 33 +-
.../google/cloud/cloud_memorystore}/__init__.py | 0
.../example_cloud_memorystore_memcached.py | 146 +
.../example_cloud_memorystore_redis.py | 220 +-
.../google/cloud/life_sciences}/__init__.py | 0
.../cloud/life_sciences}/example_life_sciences.py | 11 +-
.../google/cloud/natural_language}/__init__.py | 0
.../natural_language}/example_natural_language.py | 14 +-
.../providers/google/cloud/translate}/__init__.py | 0
.../google/cloud/translate}/example_translate.py | 36 +-
.../google/cloud/translate_speech}/__init__.py | 0
.../translate_speech}/example_translate_speech.py | 54 +-
.../system/providers/yandex/example_yandexcloud.py | 197 +
.../example_yandexcloud_dataproc_lightweight.py | 80 +
tests/www/views/test_views.py | 5 +-
tests/www/views/test_views_base.py | 2 +-
tests/www/views/test_views_grid.py | 59 +-
tests/www/views/test_views_home.py | 3 +-
367 files changed, 14786 insertions(+), 6138 deletions(-)
delete mode 100644 airflow/providers/amazon/aws/example_dags/example_ecs_fargate.py
delete mode 100644 airflow/providers/amazon/aws/example_dags/example_rds_export.py
delete mode 100644 airflow/providers/amazon/aws/example_dags/example_sagemaker_endpoint.py
create mode 100644 airflow/providers/amazon/aws/utils/connection_wrapper.py
create mode 100644 airflow/providers/elasticsearch/log/es_json_formatter.py
delete mode 100644 airflow/providers/google/cloud/example_dags/example_bigquery_to_bigquery.py
create mode 100644 airflow/providers/google/cloud/links/cloud_memorystore.py
create mode 100644 airflow/www/alias-rest-types.js
delete mode 100755 airflow/www/ask_for_recompile_assets_if_needed.sh
delete mode 100755 airflow/www/compile_assets.sh
rename airflow/www/static/css/{bootstrap-theme.css => airflow_bootstrap_theme.css} (100%)
rename airflow/www/static/js/api/{useTasks.ts => useDataset.ts} (73%)
create mode 100644 airflow/www/static/js/api/useDatasetEvents.ts
rename airflow/www/static/js/api/{useMappedInstances.js => useMappedInstances.ts} (68%)
delete mode 100644 airflow/www/static/js/api/useTasks.test.jsx
copy airflow/www/static/js/api/{useDatasets.ts => useUpstreamDatasetEvents.ts} (61%)
create mode 100644 airflow/www/static/js/components/RunTypeIcon.tsx
create mode 100644 airflow/www/static/js/components/Table/Cells.tsx
rename airflow/www/static/js/components/{ => Table}/Table.test.tsx (82%)
rename airflow/www/static/js/components/{Table.tsx => Table/index.tsx} (89%)
rename airflow/www/static/js/dag/details/{Dag.jsx => Dag.tsx} (71%)
create mode 100644 airflow/www/static/js/dag/details/dagRun/UpstreamEvents.tsx
create mode 100644 airflow/www/static/js/dag/details/taskInstance/DownstreamEvents.tsx
rename airflow/www/static/js/dag/details/taskInstance/{MappedInstances.jsx => MappedInstances.tsx} (79%)
rename airflow/www/static/js/dag/nav/{FilterBar.jsx => FilterBar.tsx} (88%)
rename airflow/www/static/js/dag/{useFilters.test.jsx => useFilters.test.tsx} (64%)
rename airflow/www/static/js/dag/{useFilters.js => useFilters.tsx} (75%)
create mode 100644 airflow/www/static/js/datasets/Details.tsx
create mode 100644 airflow/www/static/js/types/api-generated.ts
create mode 100644 airflow/www/static/js/utils/index.test.ts
create mode 100644 dev/stats/explore_pr_candidates.ipynb
create mode 100644 images/breeze/output-compile-www-assets.svg
create mode 100644 newsfragments/25147.bugfix.rst
copy airflow/operators/druid_check_operator.py => scripts/ci/pre_commit/pre_commit_compile_www_assets.py (57%)
mode change 100644 => 100755
copy airflow/operators/druid_check_operator.py => scripts/ci/pre_commit/pre_commit_compile_www_assets_dev.py (57%)
mode change 100644 => 100755
delete mode 100644 scripts/docker/compile_www_assets.sh
delete mode 100644 scripts/docker/prepare_node_modules.sh
create mode 100644 tests/dags/test_datasets.py
rename tests/{providers/google/cloud/operators/test_natural_language_system.py => decorators/test_task_group.py} (52%)
copy {airflow/api_connexion => tests/internal_api}/__init__.py (100%)
create mode 100644 tests/models/test_xcom_arg_map.py
delete mode 100644 tests/operators/test_sql.py
create mode 100644 tests/providers/amazon/aws/utils/test_connection_wrapper.py
delete mode 100644 tests/providers/google/cloud/operators/test_cloud_memorystore_system.py
delete mode 100644 tests/providers/google/cloud/operators/test_life_sciences_system.py
delete mode 100644 tests/providers/google/cloud/operators/test_translate_speech_system.py
delete mode 100644 tests/providers/google/cloud/operators/test_translate_system.py
delete mode 100644 tests/providers/google/cloud/transfers/test_bigquery_to_bigquery_system.py
create mode 100644 tests/system/providers/amazon/aws/example_ecs_fargate.py
create mode 100644 tests/system/providers/amazon/aws/example_rds_export.py
create mode 100644 tests/system/providers/amazon/aws/example_sagemaker_endpoint.py
rename {airflow/providers/google/cloud/example_dags => tests/system/providers/google/cloud/bigquery}/example_bigquery_to_mssql.py (73%)
copy {airflow/api_connexion => tests/system/providers/google/cloud/cloud_memorystore}/__init__.py (100%)
create mode 100644 tests/system/providers/google/cloud/cloud_memorystore/example_cloud_memorystore_memcached.py
rename airflow/providers/google/cloud/example_dags/example_cloud_memorystore.py => tests/system/providers/google/cloud/cloud_memorystore/example_cloud_memorystore_redis.py (52%)
copy {airflow/api_connexion => tests/system/providers/google/cloud/life_sciences}/__init__.py (100%)
rename {airflow/providers/google/cloud/example_dags => tests/system/providers/google/cloud/life_sciences}/example_life_sciences.py (92%)
copy {airflow/api_connexion => tests/system/providers/google/cloud/natural_language}/__init__.py (100%)
rename {airflow/providers/google/cloud/example_dags => tests/system/providers/google/cloud/natural_language}/example_natural_language.py (94%)
copy {airflow/api_connexion => tests/system/providers/google/cloud/translate}/__init__.py (100%)
rename {airflow/providers/google/cloud/example_dags => tests/system/providers/google/cloud/translate}/example_translate.py (64%)
copy {airflow/api_connexion => tests/system/providers/google/cloud/translate_speech}/__init__.py (100%)
rename {airflow/providers/google/cloud/example_dags => tests/system/providers/google/cloud/translate_speech}/example_translate_speech.py (65%)
create mode 100644 tests/system/providers/yandex/example_yandexcloud.py
create mode 100644 tests/system/providers/yandex/example_yandexcloud_dataproc_lightweight.py