This is an automated email from the ASF dual-hosted git repository.
ash pushed a change to branch triggerer-user-code-without-db
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 18947129773 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
discard f2e0c5e9dc8 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
discard d837c39c3dc fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
discard cfb12610569 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
omit 3affa2d0cab Rework the TriggererJobRunner to run triggers in a process
without DB access
add f7159d7b028 Support `--bundle-name` on DAG processor (#46576)
add 4111a4c2097 Use run_id for ExternalDag and TriggerDagRun links (#46546)
add c2efb867b93 Bugfix/fix sql query in edge executor (#46620)
add 732d6829fa8 Chart: Default airflow version to 2.10.5 (#46624)
add aa6f76c46de AIP-83 Logical date should be required field when
triggering run via API (#46390)
add 0c7b4d15aad AIP-84 Fix query parameters shared class instance (#46619)
add 177aae4042e Airflow 2.10.5 has been released (#46623)
add 121381da3bb Fix schema path in AWS auth manager system test due to
restructure (#46625)
add 8592188ac7a Remove AirflowContextDeprecationWarning as all context
should be clean for Airflow 3 (#46601)
add 06c9a98e34e Add missing migration for renaming execution_date to
logical_date to log table (#46634)
add dddc97973dc Disallow pymongo: 4.11.1 to fix CI tests (#46636)
add f4dfbf29bdc Handle logical_date=None rows when downgrading db (#46615)
add 0047a6886a1 change listener API, add basic support for task instance
listeners in TaskSDK, make OpenLineage provider support Airflow 3's listener
interface (#45294)
add 035060d7f38 AIP-83 amendment: Add logic for generating run_id when
logical date is None. (#46616)
add 08a08d00537 AIP-84 Add login endpoint to the public url (#46627)
add 67c4f77c1c6 Handle future dates cases in Backfill (#46017)
add c490605280c AIP-38 Add logical date to trigger DagRun form and remove
dataInterval (#46471)
add 4b651637c13 Change improper AirflowProviderDeprecationWarning ignore
to DeprecationWarning ignore for 3.12 tests (#46612)
add 69dd9c9a684 Adding uuid6 as a dependency for openlineage (#46653)
add dea2cc9afc6 AIP-84 Add back extra invalid tests (#46651)
add 34261d04ffc Remove 'allow_trigger_in_future' config (#46663)
add f4165fe5ccd Remove minimum height on elements in Flexible Form (#46591)
add ddcb7288430 AIP-72: Use runtime TI for listener tests (#46674)
add 95c3fea2dae Handle null logical date in TI.log_url (#46680)
add 340c99481cb Add `system` markers automatically when use `test_run`
(#46649)
add cb116024c54 Add assets list (#46659)
add 57ed826ce54 AIP-72: Moving task sdk logs to semantically correct
locations (#46685)
add 430ab5fce6a AIP-38 Fix import variables (#46676)
add e5452b75bbb Add global runs and instances views (#46661)
add 9ba45d1611f AIP-84 Add run_after to DAGRunResponse (#46682)
add 9c08dab6c50 Make logical_date nullable in API responses (#46666)
add c2106c4f79d Add task details overview page with duration chart.
(#46631)
add 05964803954 Double check that a dag is unpaused for autorefresh in
dags list (#46692)
add f3facfb4fab Filter dagruns by dagId when present. (#46695)
add 69c58e24976 Add deferrable mode to the PubSubPullOperator (#45835)
add cba3609f2a7 fix docstring (#46642)
add 2bf989763f5 Feat: support docker operator arg `labels` (#46643)
add 024e23ddbaf Always clean airflow installation in provider's
compatibility tests (#46693)
add 297feb88f33 Fix the remove-sources (#46628)
add 1e2f14c0ca4 Update `example_sqs` to not use `logical_date` (#46696)
add a41a470310a Update system test `example_dms_serverless` (#46684)
add 3a0509d4b0d Bump serialize-javascript, copy-webpack-plugin and
terser-webpack-plugin (#46698)
add 50c40477d8e Fix main. Fix test `test_asset_command` (#46700)
add 14199a50e23 Introduce worker.extraPorts to expose additional ports to
worker container (#46679)
add 3e011ec7997 Removing extra ticks in testing instructions (#46683)
add 77d88fb1f46 Remove validation on git dag bundle repo_url (#46705)
add 956799ad53b AIP-84 Add GET DagVersions endpoint (#46691)
add 971973725bd Fix Legacy configuration not removed or updated (#46544)
add 13c7cb46b60 Make `DagFileProcessorManager` kwargs only (#46706)
add 8dd900b6301 Set logical_date and data_interval to None for
asset-triggered dags and forbid them to be accessed in context/template (#46460)
add f50f1cea452 Change manual run data interval behavior based on
logical_date (#46512)
add 389ae2e3bfa feature: Add environment variable controlling the log
grooming frequency (#46237)
add 6d120b76f7e Update OpenLineage emmiter to cope with nullable
logical_date (#46722)
add 739f1ccec99 Ensure that we can still render log templates even when a
DagRun hasn't yet started. (#46720)
add 8f05f99e0ed Creating run backfill (#46348)
add 3ad8787a3e1 AIP-82 Introduce `BaseEventTrigger` as base class for
triggers used with event driven scheduling (#46391)
add 8b21b4e2126 Revert "Add support for serverless job in Databricks
operators (#45188)" (#46724)
add 7323548a43b AIP-79 Generate assets for Flask application in FAB
provider (#44744) (#45060)
add e3f3e0235c9 AIP-65 Add bundle url to dag version (#46723)
add 3b7206813a1 Update icons and various UI fixes (#46725)
add fe5a2ea7a0b AIP-72: Improving Operator Links Interface to Prevent User
Code Execution in Webserver (#46613)
add a10ae15440b Fix FAB static asset (#46727)
add da254edf7e2 Feature/edge worker maintenance logs user (#46712)
add 6e9c7a5a705 Fix `repo_url` kwarg for git dag bundle with https private
repos (#46710)
add 9c22411d981 Add MwaaTriggerDagRunOperator and MwaaHook to Amazon
Provider Package (#46579)
add d831da84fb4 Fix some UI usage of logical_date vs run_after (#46737)
add d1e617c48c2 Fix constraints generation for 3.9-3.11 (#46744)
add 42a94927145 Combine asset events fetching logic into one SQL query and
clean up unnecessary asset-triggered dag data (#46721)
add d7177819aec Convert 46613 to a significant newsfragment (#46745)
add 65bacad3199 allow_trigger_in_future config removal (#46667)
add c1719fa693c Fix significant format and update the checking script
(#46752)
add 973c6d64007 task-runner: call lifecycle listener methods (#46758)
add 3baa6864e22 Clarify what a significant newsfrag means (#46746)
add 8019c6447b0 AIP-84 Allow specifying an injectable path_prefix (#46597)
add c7c3de5e777 Feature/minor modification on edge worker maintenance
comment (#46755)
add 8f63b828ace Add run after to dag runs api (#46739)
add d9b4f64a5bb Add run after to grid (#46740)
add 2b8e3cddbfa Add Create Pool button on the pools page (#46736)
add 1b68875d6b6 Align layout in trigger form with flexible form (#46596)
add 57e9415ae08 Rework the TriggererJobRunner to run triggers in a process
without DB access
add c421ee8d9f6 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
add 72ad408ed36 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
add 5da5a220ea3 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
add 74fa9229d49 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
add bb23f968cd0 fixup! Rework the TriggererJobRunner to run triggers in a
process without DB access
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 (18947129773)
\
N -- N -- N refs/heads/triggerer-user-code-without-db
(bb23f968cd0)
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:
.github/ISSUE_TEMPLATE/airflow_bug_report.yml | 2 +-
.github/workflows/generate-constraints.yml | 3 +-
.github/workflows/task-sdk-tests.yml | 1 -
.github/workflows/test-provider-packages.yml | 2 +-
.gitignore | 1 +
.pre-commit-config.yaml | 21 +-
Dockerfile | 5 +-
README.md | 12 +-
RELEASE_NOTES.rst | 54 +
airflow/api/common/trigger_dag.py | 51 +-
.../api_connexion/endpoints/dag_run_endpoint.py | 22 +-
airflow/api_connexion/schemas/dag_run_schema.py | 21 +-
airflow/api_fastapi/app.py | 11 +
airflow/api_fastapi/common/parameters.py | 57 +-
airflow/api_fastapi/core_api/datamodels/dag_run.py | 17 +-
.../core_api/datamodels/dag_versions.py | 16 +
.../core_api/datamodels/task_instances.py | 2 +-
airflow/api_fastapi/core_api/datamodels/ui/grid.py | 2 +
airflow/api_fastapi/core_api/datamodels/xcom.py | 2 +-
.../api_fastapi/core_api/openapi/v1-generated.yaml | 284 +-
.../api_fastapi/core_api/routes/public/__init__.py | 4 +
.../core_api/routes/public/backfills.py | 9 +-
.../api_fastapi/core_api/routes/public/dag_run.py | 47 +-
.../core_api/routes/public/dag_versions.py | 96 +
.../routes/public/{monitor.py => login.py} | 24 +-
airflow/api_fastapi/core_api/routes/ui/dags.py | 16 +-
airflow/api_fastapi/core_api/routes/ui/grid.py | 22 +-
.../execution_api/datamodels/taskinstance.py | 4 +
.../execution_api/routes/task_instances.py | 36 +-
airflow/cli/cli_config.py | 8 +-
.../local_commands/dag_processor_command.py | 7 +-
.../commands/local_commands/fastapi_api_command.py | 5 +
.../cli/commands/remote_commands/config_command.py | 7 +-
.../cli/commands/remote_commands/task_command.py | 16 +-
airflow/config_templates/config.yml | 17 -
airflow/configuration.py | 95 +-
airflow/dag_processing/bundles/git.py | 21 +-
airflow/dag_processing/collection.py | 29 +-
airflow/dag_processing/manager.py | 11 +-
airflow/decorators/__init__.pyi | 3 +
.../example_dags/example_asset_with_watchers.py | 26 +-
airflow/example_dags/plugins/event_listener.py | 44 +-
airflow/jobs/scheduler_job_runner.py | 140 +-
airflow/jobs/triggerer_job_runner.py | 22 +-
airflow/listeners/listener.py | 8 +-
airflow/listeners/spec/taskinstance.py | 15 +-
..._execution_date_to_logical_date_and_nullable.py | 55 +-
airflow/models/abstractoperator.py | 62 -
airflow/models/backfill.py | 31 +-
airflow/models/baseoperator.py | 6 +-
airflow/models/baseoperatorlink.py | 54 +-
airflow/models/dag.py | 75 +-
airflow/models/dagrun.py | 33 +-
airflow/models/renderedtifields.py | 8 +-
airflow/models/serialized_dag.py | 2 +-
airflow/models/taskinstance.py | 15 +-
airflow/reproducible_build.yaml | 4 +-
airflow/serialization/serialized_objects.py | 140 +-
airflow/settings.py | 2 -
airflow/ti_deps/deps/runnable_exec_date_dep.py | 11 +-
airflow/timetables/base.py | 11 +-
airflow/timetables/simple.py | 38 +-
airflow/triggers/base.py | 22 +
airflow/ui/openapi-gen/queries/common.ts | 59 +
airflow/ui/openapi-gen/queries/prefetch.ts | 103 +-
airflow/ui/openapi-gen/queries/queries.ts | 110 +-
airflow/ui/openapi-gen/queries/suspense.ts | 110 +-
airflow/ui/openapi-gen/requests/schemas.gen.ts | 145 +-
airflow/ui/openapi-gen/requests/services.gen.ts | 86 +-
airflow/ui/openapi-gen/requests/types.gen.ts | 92 +-
.../components/ActionAccordion/ActionAccordion.tsx | 73 +-
airflow/ui/src/components/DagRunInfo.tsx | 75 +-
.../DurationChart.tsx} | 56 +-
airflow/ui/src/components/EditableMarkdown.tsx | 54 +
.../ui/src/components/FlexibleForm/FieldRow.tsx | 18 +-
.../Menu/MenuButton.tsx} | 38 +-
.../RunBackfillButton.tsx} | 31 +-
airflow/ui/src/components/Menu/RunBackfillForm.tsx | 217 ++
.../Menu/RunBackfillModal.tsx} | 21 +-
airflow/ui/src/components/StateIcon.tsx | 17 +-
airflow/ui/src/components/TrendCountChart.tsx | 5 +-
.../src/components/TriggerDag/TriggerDAGForm.tsx | 91 +-
.../ui/src/components/TriggerDag/useParamStore.ts | 6 +-
.../ui/{Select/Root.tsx => Popover/Arrow.tsx} | 10 +-
.../{Stat.tsx => ui/Popover/CloseTrigger.tsx} | 21 +-
.../components/ui/{Select => Popover}/Content.tsx | 16 +-
.../ui/{Dialog/index.ts => Popover/index.tsx} | 8 +-
airflow/ui/src/components/ui/index.ts | 3 +-
.../reprocessBehaviourParams.ts} | 7 +-
.../Stat.tsx => layouts/DagsLayout.tsx} | 22 +-
airflow/ui/src/layouts/Details/DagRunSelect.tsx | 2 +-
airflow/ui/src/layouts/Details/DetailsLayout.tsx | 31 +-
airflow/ui/src/layouts/Details/Graph/Graph.tsx | 2 +-
airflow/ui/src/layouts/Details/Grid/Bar.tsx | 8 +-
airflow/ui/src/layouts/Details/Grid/Grid.tsx | 2 +-
airflow/ui/src/layouts/Details/NavTabs.tsx | 38 +-
airflow/ui/src/layouts/Nav/Nav.tsx | 4 +-
airflow/ui/src/main.tsx | 2 +-
airflow/ui/src/pages/AssetsList/AssetsList.tsx | 126 +
.../ui/src/pages/AssetsList/DependencyPopover.tsx | 64 +
.../Details/Gantt => pages/AssetsList}/index.ts | 2 +-
airflow/ui/src/pages/Dag/Header.tsx | 13 +-
airflow/ui/src/pages/Dag/Overview/Overview.tsx | 13 +-
airflow/ui/src/pages/Dag/Runs/index.ts | 20 -
.../src/pages/{Dag/Runs/Runs.tsx => DagRuns.tsx} | 46 +-
airflow/ui/src/pages/DagsList/DagCard.tsx | 12 +-
airflow/ui/src/pages/DagsList/DagsList.tsx | 16 +-
airflow/ui/src/pages/DagsList/RecentRuns.tsx | 12 +-
.../Dashboard/HistoricalMetrics/AssetEvents.tsx | 2 +
.../Dashboard/HistoricalMetrics/DagRunMetrics.tsx | 2 +
.../HistoricalMetrics/HistoricalMetrics.tsx | 9 +-
.../HistoricalMetrics/TaskInstanceMetrics.tsx | 3 +-
airflow/ui/src/pages/Dashboard/Stats/Stats.tsx | 2 +-
.../AddPoolButton.tsx} | 33 +-
airflow/ui/src/pages/Pools/PoolBar.tsx | 2 +-
.../VariableForm.tsx => Pools/PoolForm.tsx} | 55 +-
airflow/ui/src/pages/Pools/Pools.tsx | 7 +-
airflow/ui/src/pages/Task/Instances.tsx | 186 -
.../src/pages/{Dag => Task}/Overview/Overview.tsx | 68 +-
.../ui/src/pages/{Dag => Task}/Overview/index.ts | 0
airflow/ui/src/pages/Task/Task.tsx | 3 +-
airflow/ui/src/pages/Task/index.ts | 1 -
airflow/ui/src/pages/{Run => }/TaskInstances.tsx | 79 +-
.../ui/src/pages/Variables/ImportVariablesForm.tsx | 5 +-
.../queries/{useAddVariable.ts => useAddPool.ts} | 26 +-
airflow/ui/src/queries/useCreateBackfill.ts | 86 +
...stancesDryRun.ts => useCreateBackfillDryRun.ts} | 22 +-
airflow/ui/src/queries/useDagParams.ts | 2 +-
airflow/ui/src/queries/useDags.tsx | 4 +-
airflow/ui/src/queries/useTrigger.ts | 41 +-
airflow/ui/src/router.tsx | 38 +-
airflow/utils/context.py | 7 +-
airflow/utils/log/file_task_handler.py | 34 +-
airflow/utils/types.py | 11 +-
airflow/www/app.py | 4 +-
airflow/www/views.py | 33 +-
chart/Chart.yaml | 20 +-
chart/newsfragments/44959.significant.rst | 3 -
chart/newsfragments/46624.significant.rst | 3 +
.../dag-processor/dag-processor-deployment.yaml | 4 +
.../templates/scheduler/scheduler-deployment.yaml | 4 +
.../templates/triggerer/triggerer-deployment.yaml | 4 +
chart/templates/workers/worker-deployment.yaml | 7 +
chart/values.schema.json | 21 +-
chart/values.yaml | 15 +-
contributing-docs/08_static_code_checks.rst | 2 +
contributing-docs/16_contribution_workflow.rst | 1 +
contributing-docs/testing/unit_tests.rst | 1 -
dev/README_RELEASE_AIRFLOW.md | 2 +-
dev/breeze/doc/images/output_static-checks.svg | 8 +-
dev/breeze/doc/images/output_static-checks.txt | 2 +-
dev/breeze/src/airflow_breeze/pre_commit_ids.py | 1 +
dev/breeze/src/airflow_breeze/utils/uv_utils.py | 2 +-
docker_tests/test_docker_compose_quick_start.py | 6 +-
.../administration-and-deployment/listeners.rst | 20 +-
.../administration-and-deployment/scheduler.rst | 9 -
docs/apache-airflow/img/airflow_erd.sha256 | 2 +-
docs/apache-airflow/img/airflow_erd.svg | 3940 ++++++++++----------
.../installation/supported-versions.rst | 2 +-
docs/apache-airflow/migrations-ref.rst | 2 +-
docs/apache-airflow/templates-ref.rst | 2 +
docs/spelling_wordlist.txt | 1 +
generated/PYPI_README.md | 10 +-
generated/provider_dependencies.json | 5 +-
kubernetes_tests/test_base.py | 7 +-
kubernetes_tests/test_kubernetes_pod_operator.py | 27 +-
newsfragments/46231.significant.rst | 6 +-
newsfragments/46375.significant.rst | 2 +-
newsfragments/46408.significant.rst | 6 +-
newsfragments/46613.significant.rst | 44 +
newsfragments/46663.significant.rst | 31 +
newsfragments/aip-66.significant.rst | 8 +
providers/amazon/docs/changelog.rst | 5 +
providers/amazon/docs/operators/mwaa.rst | 64 +
providers/amazon/provider.yaml | 6 +
.../src/airflow/providers/amazon/aws/hooks/mwaa.py | 85 +
.../airflow/providers/amazon/aws/operators/dms.py | 4 -
.../airflow/providers/amazon/aws/operators/mwaa.py | 109 +
.../airflow/providers/amazon/aws/waiters/dms.json | 12 +
.../airflow/providers/amazon/get_provider_info.py | 8 +
.../provider_tests/amazon/aws/hooks/test_emr.py | 6 +-
.../provider_tests/amazon/aws/hooks/test_mwaa.py | 130 +
.../amazon/aws/links/test_base_aws.py | 11 +-
.../amazon/aws/operators/test_dms.py | 30 +-
.../amazon/aws/operators/test_mwaa.py | 80 +
.../system/amazon/aws/example_dms_serverless.py | 129 +-
.../{example_mongo_to_s3.py => example_mwaa.py} | 74 +-
.../amazon/tests/system/amazon/aws/example_sqs.py | 4 +-
.../amazon/aws/tests/test_aws_auth_manager.py | 6 +-
.../cncf/kubernetes/operators/test_job.py | 21 +-
.../cncf/kubernetes/operators/test_pod.py | 4 +-
.../kubernetes/operators/test_spark_kubernetes.py | 4 +-
.../databricks/docs/operators/jobs_create.rst | 1 -
providers/databricks/docs/operators/submit_run.rst | 1 -
providers/databricks/docs/operators/task.rst | 7 -
.../providers/databricks/operators/databricks.py | 23 +-
.../databricks/operators/databricks_workflow.py | 10 -
.../databricks/operators/test_databricks.py | 102 +-
.../operators/test_databricks_workflow.py | 12 -
.../tests/system/databricks/example_databricks.py | 23 -
.../provider_tests/dbt/cloud/operators/test_dbt.py | 2 +-
.../airflow/providers/docker/operators/docker.py | 5 +
.../provider_tests/docker/operators/test_docker.py | 13 +
providers/edge/README.rst | 6 +-
providers/edge/docs/changelog.rst | 27 +
providers/edge/provider.yaml | 2 +-
providers/edge/pyproject.toml | 6 +-
.../edge/src/airflow/providers/edge/__init__.py | 2 +-
.../providers/edge/executors/edge_executor.py | 11 +-
.../airflow/providers/edge/get_provider_info.py | 2 +-
.../providers/edge/plugins/edge_executor_plugin.py | 27 +
.../edge/plugins/templates/edge_worker_hosts.html | 4 +-
.../provider_tests/edge/cli/test_edge_command.py | 2 +
.../edge/executors/test_edge_executor.py | 1 +
.../edge/plugins/test_edge_executor_plugin.py | 31 +
.../providers}/3rd-party-licenses/LICENSES-ui.txt | 6 +-
.../airflow/providers/fab/www/package-lock.json | 666 +---
.../fab/src/airflow/providers/fab/www/package.json | 4 +-
.../airflowDefaultTheme.feec4a4075c2f3d6ae01.css | 33 +
.../airflowDefaultTheme.feec4a4075c2f3d6ae01.js | 1 +
.../providers/fab/www/static/dist/d3-tip.js | 1 +
.../dist/loadingDots.48ab7d5b04e66f2686b0.css | 11 +-
.../dist/loadingDots.48ab7d5b04e66f2686b0.js | 1 +
.../www/static/dist/main.b585926afc96bd076c4f.css | 18 +
.../www/static/dist/main.b585926afc96bd076c4f.js | 2 +
.../dist/main.b585926afc96bd076c4f.js.LICENSE.txt | 0
.../providers/fab/www/static/dist/manifest.json | 34 +
.../dist/materialIcons.57390fa60d8f61175334.css | 18 +
.../dist/materialIcons.57390fa60d8f61175334.js | 1 +
.../www/static/dist/moment.4d28b37c229bdfc54575.js | 2 +
.../moment.4d28b37c229bdfc54575.js.LICENSE.txt | 11 +
.../fab/www/static/dist/oss-licenses.json | 29 +
.../airflow/providers/fab/www/webpack.config.js | 19 +-
.../api_endpoints/test_dag_run_endpoint.py | 2 +
.../api_endpoints/test_xcom_endpoint.py | 14 +-
.../providers/google/cloud/operators/pubsub.py | 34 +
.../google/cloud/operators/test_dataproc.py | 112 +-
.../google/cloud/operators/test_pubsub.py | 20 +
.../microsoft/azure/operators/test_data_factory.py | 7 +-
.../microsoft/azure/operators/test_powerbi.py | 2 +-
.../microsoft/azure/operators/test_synapse.py | 2 +-
.../microsoft/azure/sensors/test_wasb.py | 8 +-
providers/mongo/README.rst | 8 +-
providers/mongo/pyproject.toml | 2 +-
.../airflow/providers/mongo/get_provider_info.py | 2 +-
providers/openlineage/README.rst | 1 +
providers/openlineage/pyproject.toml | 1 +
.../providers/openlineage/get_provider_info.py | 1 +
.../providers/openlineage/plugins/listener.py | 246 +-
.../openlineage/utils/selective_enable.py | 6 +-
.../airflow/providers/openlineage/utils/utils.py | 30 +-
.../openlineage/extractors/test_manager.py | 169 +-
.../openlineage/plugins/test_execution.py | 5 +-
.../openlineage/plugins/test_listener.py | 1693 ++++++---
.../snowflake/operators/test_snowflake.py | 4 +-
.../airflow/providers/standard/operators/python.py | 5 +
.../providers/standard/operators/trigger_dagrun.py | 27 +-
.../providers/standard/sensors/external_task.py | 20 +-
.../airflow/providers/standard/triggers/file.py | 60 +-
.../standard/operators/test_python.py | 9 +-
.../provider_tests/standard/triggers/test_file.py | 44 +-
pyproject.toml | 1 -
scripts/ci/docker-compose/remove-sources.yml | 2 +
scripts/ci/pre_commit/check_deprecations.py | 5 +-
...compile_www_assets.py => compile_fab_assets.py} | 23 +-
scripts/ci/pre_commit/compile_www_assets.py | 21 +-
.../significant_newsfragments_checker.py | 6 +-
scripts/ci/pre_commit/supported_versions.py | 2 +-
scripts/ci/pre_commit/template_context_key_sync.py | 16 +-
scripts/ci/testing/summarize_captured_warnings.py | 1 -
scripts/docker/clean-logs.sh | 3 +-
.../src/airflow/sdk/api/datamodels/_generated.py | 2 +
.../src/airflow/sdk/definitions/asset/__init__.py | 22 +-
task_sdk/src/airflow/sdk/definitions/context.py | 2 +
task_sdk/src/airflow/sdk/definitions/dag.py | 4 -
task_sdk/src/airflow/sdk/execution_time/comms.py | 1 +
.../src/airflow/sdk/execution_time/supervisor.py | 7 +-
.../src/airflow/sdk/execution_time/task_runner.py | 105 +-
task_sdk/tests/conftest.py | 18 +-
task_sdk/tests/execution_time/test_supervisor.py | 129 +-
task_sdk/tests/execution_time/test_task_runner.py | 251 +-
tests/always/test_project_structure.py | 3 +
.../endpoints/test_dag_run_endpoint.py | 73 +-
.../endpoints/test_extra_link_endpoint.py | 5 +
.../api_connexion/endpoints/test_xcom_endpoint.py | 70 +-
tests/api_connexion/schemas/test_dag_run_schema.py | 19 +-
tests/api_fastapi/conftest.py | 59 +-
.../core_api/routes/public/test_backfills.py | 70 +-
.../core_api/routes/public/test_dag_run.py | 145 +-
.../core_api/routes/public/test_dag_versions.py | 228 ++
.../core_api/routes/public/test_extra_links.py | 138 +-
.../core_api/routes/public/test_login.py | 54 +
.../core_api/routes/public/test_task_instances.py | 9 +-
.../core_api/routes/public/test_xcom.py | 5 +-
tests/api_fastapi/core_api/routes/test_routes.py | 1 +
tests/api_fastapi/core_api/routes/ui/test_dags.py | 11 +-
tests/api_fastapi/core_api/routes/ui/test_grid.py | 3456 +++--------------
.../execution_api/routes/test_task_instances.py | 3 +-
tests/callbacks/test_callback_requests.py | 1 +
tests/charts/log_groomer.py | 43 +-
.../local_commands/test_dag_processor_command.py | 19 +-
.../local_commands/test_fastapi_api_command.py | 45 +-
.../commands/remote_commands/test_asset_command.py | 2 +
.../remote_commands/test_config_command.py | 3 +-
.../commands/remote_commands/test_dag_command.py | 12 +-
.../commands/remote_commands/test_task_command.py | 13 +-
tests/dag_processing/bundles/test_git.py | 81 +-
tests/dag_processing/test_manager.py | 18 +
tests/executors/test_local_executor.py | 3 +
tests/jobs/test_scheduler_job.py | 23 +-
tests/listeners/class_listener.py | 8 +-
tests/listeners/empty_listener.py | 2 +-
tests/listeners/file_write_listener.py | 8 +-
tests/listeners/full_listener.py | 6 +-
tests/listeners/partial_listener.py | 2 +-
tests/listeners/slow_listener.py | 2 +-
tests/listeners/throwing_listener.py | 2 +-
tests/listeners/very_slow_listener.py | 2 +-
tests/listeners/xcom_listener.py | 4 +-
tests/models/test_dag.py | 15 +-
tests/models/test_dagrun.py | 13 +-
tests/models/test_taskinstance.py | 9 +-
tests/models/test_xcom.py | 4 +-
tests/operators/test_trigger_dagrun.py | 14 +-
tests/plugins/test_plugins_manager.py | 29 +-
tests/sensors/test_external_task_sensor.py | 6 +-
tests/serialization/test_dag_serialization.py | 63 +-
tests/serialization/test_serialized_objects.py | 4 +-
tests/ti_deps/deps/test_runnable_exec_date_dep.py | 38 +-
tests/timetables/test_assets_timetable.py | 24 +-
tests/utils/test_cli_util.py | 2 +-
tests/utils/test_log_handlers.py | 11 +-
tests/utils/test_state.py | 2 +-
tests/www/views/test_views_extra_links.py | 219 +-
tests/www/views/test_views_trigger_dag.py | 12 +
tests_common/pytest_plugin.py | 81 +-
tests_common/test_utils/compat.py | 2 +
tests_common/test_utils/mock_operators.py | 4 +
tests_common/test_utils/system_tests.py | 2 +
339 files changed, 10363 insertions(+), 8752 deletions(-)
create mode 100644 airflow/api_fastapi/core_api/routes/public/dag_versions.py
copy airflow/api_fastapi/core_api/routes/public/{monitor.py => login.py} (57%)
rename airflow/ui/src/{pages/Dag/Overview/RunDuration.tsx =>
components/DurationChart.tsx} (65%)
create mode 100644 airflow/ui/src/components/EditableMarkdown.tsx
copy airflow/ui/src/{layouts/Nav/BrowseButton.tsx =>
components/Menu/MenuButton.tsx} (60%)
copy airflow/ui/src/components/{TriggerDag/TriggerDAGButton.tsx =>
Menu/RunBackfillButton.tsx} (63%)
create mode 100644 airflow/ui/src/components/Menu/RunBackfillForm.tsx
copy airflow/ui/src/{layouts/Nav/TimezoneModal.tsx =>
components/Menu/RunBackfillModal.tsx} (61%)
copy airflow/ui/src/components/ui/{Select/Root.tsx => Popover/Arrow.tsx} (73%)
copy airflow/ui/src/components/{Stat.tsx => ui/Popover/CloseTrigger.tsx} (65%)
copy airflow/ui/src/components/ui/{Select => Popover}/Content.tsx (73%)
copy airflow/ui/src/components/ui/{Dialog/index.ts => Popover/index.tsx} (86%)
copy airflow/ui/src/{components/ActionAccordion/index.tsx =>
constants/reprocessBehaviourParams.ts} (81%)
copy airflow/ui/src/{components/Stat.tsx => layouts/DagsLayout.tsx} (71%)
create mode 100644 airflow/ui/src/pages/AssetsList/AssetsList.tsx
create mode 100644 airflow/ui/src/pages/AssetsList/DependencyPopover.tsx
copy airflow/ui/src/{layouts/Details/Gantt => pages/AssetsList}/index.ts (96%)
delete mode 100644 airflow/ui/src/pages/Dag/Runs/index.ts
rename airflow/ui/src/pages/{Dag/Runs/Runs.tsx => DagRuns.tsx} (84%)
copy airflow/ui/src/pages/{Variables/ManageVariable/AddVariableButton.tsx =>
Pools/AddPoolButton.tsx} (70%)
copy airflow/ui/src/pages/{Variables/ManageVariable/VariableForm.tsx =>
Pools/PoolForm.tsx} (67%)
delete mode 100644 airflow/ui/src/pages/Task/Instances.tsx
copy airflow/ui/src/pages/{Dag => Task}/Overview/Overview.tsx (59%)
copy airflow/ui/src/pages/{Dag => Task}/Overview/index.ts (100%)
rename airflow/ui/src/pages/{Run => }/TaskInstances.tsx (80%)
copy airflow/ui/src/queries/{useAddVariable.ts => useAddPool.ts} (63%)
create mode 100644 airflow/ui/src/queries/useCreateBackfill.ts
copy airflow/ui/src/queries/{useClearTaskInstancesDryRun.ts =>
useCreateBackfillDryRun.ts} (64%)
delete mode 100644 chart/newsfragments/44959.significant.rst
create mode 100644 chart/newsfragments/46624.significant.rst
create mode 100644 newsfragments/46613.significant.rst
create mode 100644 newsfragments/46663.significant.rst
create mode 100644 providers/amazon/docs/operators/mwaa.rst
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/hooks/mwaa.py
create mode 100644
providers/amazon/src/airflow/providers/amazon/aws/operators/mwaa.py
create mode 100644
providers/amazon/tests/provider_tests/amazon/aws/hooks/test_mwaa.py
create mode 100644
providers/amazon/tests/provider_tests/amazon/aws/operators/test_mwaa.py
copy providers/amazon/tests/system/amazon/aws/{example_mongo_to_s3.py =>
example_mwaa.py} (51%)
copy providers/fab/{ =>
src/airflow/providers}/3rd-party-licenses/LICENSES-ui.txt (97%)
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/airflowDefaultTheme.feec4a4075c2f3d6ae01.css
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/airflowDefaultTheme.feec4a4075c2f3d6ae01.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/d3-tip.js
copy airflow/ui/rules/levels.js =>
providers/fab/src/airflow/providers/fab/www/static/dist/loadingDots.48ab7d5b04e66f2686b0.css
(64%)
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/loadingDots.48ab7d5b04e66f2686b0.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/main.b585926afc96bd076c4f.css
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/main.b585926afc96bd076c4f.js
copy airflow/ui/src/utils/advancedSelectStyles.ts =>
providers/fab/src/airflow/providers/fab/www/static/dist/main.b585926afc96bd076c4f.js.LICENSE.txt
(100%)
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/manifest.json
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/materialIcons.57390fa60d8f61175334.css
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/materialIcons.57390fa60d8f61175334.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/moment.4d28b37c229bdfc54575.js
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/moment.4d28b37c229bdfc54575.js.LICENSE.txt
create mode 100644
providers/fab/src/airflow/providers/fab/www/static/dist/oss-licenses.json
copy scripts/ci/pre_commit/{compile_www_assets.py => compile_fab_assets.py}
(84%)
mode change 100644 => 100755 scripts/docker/clean-logs.sh
create mode 100644
tests/api_fastapi/core_api/routes/public/test_dag_versions.py
create mode 100644 tests/api_fastapi/core_api/routes/public/test_login.py
