This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch ci-upgrade-main
in repository https://gitbox.apache.org/repos/asf/airflow.git
discard 317f4cf4254 [main] CI: Upgrade important CI environment
add c5bbd4b087a Instruct agents to reduce direct AirflowException usage
(#68656)
add 272904f4c03 prepare-providers-doc skill: batch classification to cut
sub-agents (#68653)
add 844a892cb99 Bump `clickhouse-connect>=1.3.0` (#68400)
add 9140ce5aee1 Percent-encode API client path params for keys with
slashes (#68667)
add bf590ccd179 UI E2E: Clarify HITL e2e helper parameter name and error
message (#68646)
add 3d0fb9f8993 docs: add wait policy examples to asset partition example
(#68658)
add bd9270d5441 Fix bulk create+overwrite silently resetting unset fields
on pools and connections (#68645)
add 6b41214e395 Enforce pool team ownership in scheduling loop (#68649)
add 674544c8918 Add openlineage system tests for missing use cases (#68664)
add b6bf6a83b51 UI: Fix misleading Calendar Total Runs coloring behavior
(#67595)
add fa273d83075 Fix triggerer crash when trigger subclass does not call
`super().__init__()` (#68636)
add cf2d0475312 Bump eslint (#68681)
add 88b89283722 Add 'classify-provider-changes' breeze command for
deterministic change classification (#68215)
add 2746dcb1a24 Fix mypy errors for task_instance access in provider
triggers (#68685)
add 57593bb1881 Add code mode (Monty sandbox) to common.ai AgentOperator
(#68407)
add db26df7d165 fix: Verify durable cached agent steps match the request
before replay (#68372)
add db9fa4289fe Populate partition_date when manually triggering
partitioned Dags (#68458)
add d9b363c630e UI: Fix inconsistent padding between Dag Runs and Task
Instances list views (#68689)
add 8050e7c7297 Fix the gap of Taiwanese Mandarin translation (#68668)
add 7cc1d693b7e Add team_name tag to remaining multi-team metrics (#68601)
add 0508dea89db Fix Databricks operators with templated json payloads
(#68519)
add 9928bb3292e Use async versions of CertificateCredential and
ClientSecretCredential in KiotaRequestAdapterHook (#68375)
add 4d5046d78ce Adding example dag for task state store with mapped tasks
(#68670)
add 50271018585 Fixed "AttributeError: 'NoneType' object has no attribute
'close'" for SmtpHook (#62409)
add 71532401a01 Small operator improvements in openlineage system tests
(#68677)
add c59f4cd8bb7 Fix TaskSDK swallowing errors when Variable.set() or
Variable.delete() fails (#68542)
add 91ba4a23a89 Fix fab deserialize user session leak (#68100)
add 59fc9e284dd Skip asset-change registration for tasks with no outlets
(#68687)
add aa0609f0867 Add team_name tag to dag processor metrics for multi-team
deployments (#68599)
add 8b46c346ed8 Add team_name tag to asset metrics for multi-team
deployments (#68367)
add d7d84b46d81 Indent dag-run span TODO comment continuation lines
(#68643)
add be44ad1ac6c Make head sampling possible in airflow (#68591)
add 9c4908019a3 Add Ray constraints for Python 3.14 in Google provider
(#68710)
add 531bfab9dee Add `message_history` to `AgentOperator` for multi-turn
agent sessions (#68648)
add b237fd02d25 Update multi-team docs for the 3.3 release (#68728)
add 583e54fc65f Add segment fan-out example to asset partition example Dag
(#68722)
add 0236c5775db Prepare provider documentation 2026-06-16 (#68642)
add ddb63a4a1a1 Resolve common.ai '# use next version' pin to
common-compat 1.15.0 (#68740)
add 7e7e4a95e0c Add update-providers-next-version step to provider docs
skill (#68739)
add 23a3de15e5a [main] CI: Upgrade important CI environment
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 (317f4cf4254)
\
N -- N -- N refs/heads/ci-upgrade-main (23a3de15e5a)
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:
.../prepare-providers-documentation/SKILL.md | 220 ++-
.github/instructions/code-review.instructions.md | 2 +-
AGENTS.md | 2 +-
airflow-core/docs/core-concepts/multi-team.rst | 162 ++-
airflow-core/src/airflow/api/common/trigger_dag.py | 3 +
.../api_fastapi/core_api/datamodels/dag_run.py | 4 +
.../api_fastapi/core_api/routes/public/dag_run.py | 1 +
.../core_api/services/public/connections.py | 7 +-
.../api_fastapi/core_api/services/public/pools.py | 9 +-
.../api_fastapi/execution_api/routes/dag_runs.py | 7 +-
.../execution_api/routes/task_instances.py | 10 +
airflow-core/src/airflow/assets/manager.py | 10 +-
.../src/airflow/config_templates/config.yml | 3 +-
airflow-core/src/airflow/dag_processing/manager.py | 111 +-
.../src/airflow/dag_processing/processor.py | 16 +-
.../example_dags/example_asset_partition.py | 128 +-
.../example_task_state_store_mapped.py | 59 +
airflow-core/src/airflow/exceptions.py | 7 +-
.../src/airflow/jobs/scheduler_job_runner.py | 25 +-
.../src/airflow/jobs/triggerer_job_runner.py | 10 +-
airflow-core/src/airflow/models/callback.py | 12 +-
airflow-core/src/airflow/models/dagrun.py | 38 +-
airflow-core/src/airflow/models/taskinstance.py | 10 +-
airflow-core/src/airflow/timetables/base.py | 39 +
airflow-core/src/airflow/timetables/simple.py | 42 +
airflow-core/src/airflow/timetables/trigger.py | 23 +-
airflow-core/src/airflow/triggers/base.py | 4 +-
.../ui/public/i18n/locales/zh-TW/common.json | 5 +-
.../ui/public/i18n/locales/zh-TW/dashboard.json | 12 +
.../airflow/ui/public/i18n/locales/zh-TW/hitl.json | 14 +
.../ui/src/pages/Dag/Calendar/CalendarCell.tsx | 10 +-
.../ui/src/pages/Dag/Calendar/CalendarLegend.tsx | 109 +-
.../ui/src/pages/Dag/Calendar/CalendarTooltip.tsx | 1 +
.../src/pages/Dag/Calendar/calendarUtils.test.ts | 134 +-
.../ui/src/pages/Dag/Calendar/calendarUtils.ts | 164 ++-
.../src/airflow/ui/src/pages/Dag/Calendar/types.ts | 4 +-
.../pages/TaskInstances/TaskInstancesFilter.tsx | 14 +-
airflow-core/src/airflow/ui/src/queryClient.ts | 6 +
.../ui/tests/e2e/components/HITLReviewDrawer.ts | 4 +-
.../ui/tests/e2e/components/HITLReviewModal.ts | 4 +-
.../src/airflow/ui/tests/e2e/utils/api/hitl.ts | 2 +-
airflow-core/src/airflow/utils/email.py | 4 +-
.../tests/unit/api/common/test_trigger_dag.py | 68 +
.../core_api/routes/public/test_connections.py | 34 +
.../core_api/routes/public/test_dag_run.py | 84 +-
.../core_api/routes/public/test_pools.py | 65 +
.../execution_api/versions/head/test_dag_runs.py | 27 +-
.../versions/head/test_task_instances.py | 16 +
airflow-core/tests/unit/assets/test_manager.py | 57 +-
.../tests/unit/dag_processing/test_manager.py | 292 ++++
.../tests/unit/dag_processing/test_processor.py | 77 +
airflow-core/tests/unit/jobs/test_scheduler_job.py | 125 ++
airflow-core/tests/unit/jobs/test_triggerer_job.py | 77 +
airflow-core/tests/unit/models/test_callback.py | 45 +
airflow-core/tests/unit/models/test_dagrun.py | 77 +-
.../tests/unit/models/test_taskinstance.py | 56 +
.../unit/timetables/test_partitioned_timetable.py | 23 +
.../tests/unit/triggers/test_base_trigger.py | 19 +
airflow-core/tests/unit/utils/test_email.py | 6 +-
dev/README_RELEASE_PROVIDERS.md | 23 +
dev/breeze/doc/09_release_management_tasks.rst | 19 +
.../doc/images/output_release-management.svg | 96 +-
.../doc/images/output_release-management.txt | 2 +-
...elease-management_classify-provider-changes.svg | 200 +++
...elease-management_classify-provider-changes.txt | 1 +
.../output_setup_check-all-params-in-groups.svg | 10 +-
.../output_setup_check-all-params-in-groups.txt | 2 +-
.../output_setup_regenerate-command-images.svg | 80 +-
.../output_setup_regenerate-command-images.txt | 2 +-
.../commands/release_management_commands.py | 109 ++
.../commands/release_management_commands_config.py | 19 +
.../prepare_providers/provider_documentation.py | 44 +
dev/breeze/tests/test_provider_documentation.py | 42 +
dev/breeze/uv.lock | 196 +--
docs/spelling_wordlist.txt | 2 +
generated/provider_dependencies.json | 6 +-
generated/provider_dependencies.json.sha256sum | 2 +-
providers/.last_release_date.txt | 2 +-
providers/alibaba/README.rst | 6 +-
providers/alibaba/docs/changelog.rst | 11 +
providers/alibaba/docs/index.rst | 6 +-
providers/alibaba/provider.yaml | 3 +-
providers/alibaba/pyproject.toml | 6 +-
.../src/airflow/providers/alibaba/__init__.py | 2 +-
providers/amazon/README.rst | 6 +-
providers/amazon/docs/changelog.rst | 27 +
providers/amazon/docs/index.rst | 6 +-
providers/amazon/provider.yaml | 3 +-
providers/amazon/pyproject.toml | 6 +-
.../src/airflow/providers/amazon/__init__.py | 2 +-
.../airflow/providers/amazon/aws/triggers/emr.py | 19 +-
.../apache/druid/docs/.latest-doc-only-change.txt | 2 +-
providers/apache/hdfs/README.rst | 6 +-
providers/apache/hdfs/docs/changelog.rst | 11 +
providers/apache/hdfs/docs/index.rst | 6 +-
providers/apache/hdfs/provider.yaml | 3 +-
providers/apache/hdfs/pyproject.toml | 6 +-
.../src/airflow/providers/apache/hdfs/__init__.py | 2 +-
providers/apache/livy/README.rst | 6 +-
providers/apache/livy/docs/changelog.rst | 11 +
providers/apache/livy/docs/index.rst | 6 +-
providers/apache/livy/provider.yaml | 3 +-
providers/apache/livy/pyproject.toml | 6 +-
.../src/airflow/providers/apache/livy/__init__.py | 2 +-
providers/apache/spark/README.rst | 6 +-
providers/apache/spark/docs/changelog.rst | 15 +
providers/apache/spark/docs/index.rst | 6 +-
providers/apache/spark/provider.yaml | 3 +-
providers/apache/spark/pyproject.toml | 6 +-
.../src/airflow/providers/apache/spark/__init__.py | 2 +-
providers/celery/docs/.latest-doc-only-change.txt | 2 +-
providers/clickhousedb/README.rst | 2 +-
providers/clickhousedb/docs/commits.rst | 2 +-
providers/clickhousedb/docs/index.rst | 2 +-
providers/clickhousedb/pyproject.toml | 2 +-
providers/cncf/kubernetes/README.rst | 6 +-
providers/cncf/kubernetes/docs/changelog.rst | 20 +
providers/cncf/kubernetes/docs/index.rst | 6 +-
providers/cncf/kubernetes/provider.yaml | 3 +-
providers/cncf/kubernetes/pyproject.toml | 6 +-
.../airflow/providers/cncf/kubernetes/__init__.py | 2 +-
.../providers/cncf/kubernetes/triggers/pod.py | 19 +-
providers/common/ai/README.rst | 9 +-
providers/common/ai/docs/changelog.rst | 57 +
providers/common/ai/docs/index.rst | 8 +-
providers/common/ai/docs/operators/agent.rst | 136 +-
providers/common/ai/provider.yaml | 3 +-
providers/common/ai/pyproject.toml | 13 +-
.../ai/src/airflow/providers/common/ai/__init__.py | 2 +-
.../providers/common/ai/durable/caching_model.py | 50 +-
.../providers/common/ai/durable/caching_toolset.py | 33 +-
.../providers/common/ai/durable/fingerprint.py | 162 +++
.../providers/common/ai/durable/step_counter.py | 4 +-
.../airflow/providers/common/ai/durable/storage.py | 77 +-
.../common/ai/example_dags/example_agent.py | 81 +-
.../airflow/providers/common/ai/operators/agent.py | 127 +-
.../airflow/providers/common/ai/toolsets/hook.py | 7 +
.../airflow/providers/common/ai/toolsets/sql.py | 4 +
.../providers/common/ai/utils/tool_definition.py | 44 +
.../unit/common/ai/durable/test_caching_model.py | 94 +-
.../unit/common/ai/durable/test_caching_toolset.py | 78 +-
.../unit/common/ai/durable/test_fingerprint.py | 212 +++
.../common/ai/durable/test_replay_verification.py | 138 ++
.../tests/unit/common/ai/durable/test_storage.py | 135 +-
.../tests/unit/common/ai/operators/test_agent.py | 229 ++-
.../ai/tests/unit/common/ai/toolsets/test_hook.py | 11 +
.../ai/tests/unit/common/ai/toolsets/test_sql.py | 11 +
.../unit/common/ai/utils/test_tool_definition.py | 21 +-
providers/databricks/README.rst | 6 +-
providers/databricks/docs/changelog.rst | 29 +
providers/databricks/docs/index.rst | 6 +-
providers/databricks/provider.yaml | 3 +-
providers/databricks/pyproject.toml | 6 +-
.../src/airflow/providers/databricks/__init__.py | 2 +-
.../src/airflow/providers/databricks/exceptions.py | 4 +
.../providers/databricks/operators/databricks.py | 432 ++++--
.../unit/databricks/operators/test_databricks.py | 399 +++++-
providers/dbt/cloud/README.rst | 6 +-
providers/dbt/cloud/docs/changelog.rst | 11 +
providers/dbt/cloud/docs/index.rst | 6 +-
providers/dbt/cloud/provider.yaml | 3 +-
providers/dbt/cloud/pyproject.toml | 6 +-
.../src/airflow/providers/dbt/cloud/__init__.py | 2 +-
providers/edge3/README.rst | 6 +-
providers/edge3/docs/changelog.rst | 26 +
providers/edge3/docs/index.rst | 6 +-
providers/edge3/provider.yaml | 3 +-
providers/edge3/pyproject.toml | 6 +-
.../edge3/src/airflow/providers/edge3/__init__.py | 2 +-
providers/elasticsearch/README.rst | 6 +-
providers/elasticsearch/docs/changelog.rst | 11 +
providers/elasticsearch/docs/index.rst | 6 +-
providers/elasticsearch/provider.yaml | 3 +-
providers/elasticsearch/pyproject.toml | 6 +-
.../airflow/providers/elasticsearch/__init__.py | 2 +-
providers/fab/README.rst | 6 +-
providers/fab/docs/changelog.rst | 31 +
providers/fab/docs/index.rst | 6 +-
providers/fab/provider.yaml | 3 +-
providers/fab/pyproject.toml | 6 +-
.../fab/src/airflow/providers/fab/__init__.py | 2 +-
.../providers/fab/auth_manager/fab_auth_manager.py | 11 +-
.../fab/src/airflow/providers/fab/www/package.json | 2 +-
.../src/airflow/providers/fab/www/pnpm-lock.yaml | 37 +-
.../unit/fab/auth_manager/test_fab_auth_manager.py | 42 +-
providers/ftp/README.rst | 6 +-
providers/ftp/docs/changelog.rst | 11 +
providers/ftp/docs/index.rst | 6 +-
providers/ftp/provider.yaml | 3 +-
providers/ftp/pyproject.toml | 6 +-
.../ftp/src/airflow/providers/ftp/__init__.py | 2 +-
providers/git/docs/.latest-doc-only-change.txt | 2 +-
providers/google/README.rst | 10 +-
providers/google/docs/changelog.rst | 35 +
providers/google/docs/index.rst | 8 +-
providers/google/provider.yaml | 3 +-
providers/google/pyproject.toml | 10 +-
.../src/airflow/providers/google/__init__.py | 2 +-
.../airflow/providers/google/cloud/hooks/ray.py | 5 -
.../providers/google/cloud/triggers/bigquery.py | 40 +-
.../providers/google/cloud/triggers/dataproc.py | 120 +-
providers/hashicorp/README.rst | 6 +-
providers/hashicorp/docs/changelog.rst | 11 +
providers/hashicorp/docs/index.rst | 6 +-
providers/hashicorp/provider.yaml | 3 +-
providers/hashicorp/pyproject.toml | 6 +-
.../src/airflow/providers/hashicorp/__init__.py | 2 +-
providers/http/README.rst | 6 +-
providers/http/docs/changelog.rst | 17 +
providers/http/docs/index.rst | 6 +-
providers/http/provider.yaml | 3 +-
providers/http/pyproject.toml | 6 +-
.../http/src/airflow/providers/http/__init__.py | 2 +-
providers/informatica/README.rst | 8 +-
providers/informatica/docs/changelog.rst | 6 +
providers/informatica/docs/index.rst | 6 +-
providers/informatica/provider.yaml | 3 +-
providers/informatica/pyproject.toml | 6 +-
.../src/airflow/providers/informatica/__init__.py | 2 +-
providers/keycloak/README.rst | 6 +-
providers/keycloak/docs/changelog.rst | 11 +
providers/keycloak/docs/index.rst | 6 +-
providers/keycloak/provider.yaml | 3 +-
providers/keycloak/pyproject.toml | 6 +-
.../src/airflow/providers/keycloak/__init__.py | 2 +-
providers/microsoft/azure/README.rst | 10 +-
providers/microsoft/azure/docs/changelog.rst | 19 +
providers/microsoft/azure/docs/index.rst | 6 +-
providers/microsoft/azure/provider.yaml | 3 +-
providers/microsoft/azure/pyproject.toml | 6 +-
.../airflow/providers/microsoft/azure/__init__.py | 2 +-
.../providers/microsoft/azure/hooks/msgraph.py | 52 +-
.../unit/microsoft/azure/hooks/test_msgraph.py | 160 ++-
providers/microsoft/mssql/README.rst | 6 +-
providers/microsoft/mssql/docs/changelog.rst | 11 +
providers/microsoft/mssql/docs/index.rst | 6 +-
providers/microsoft/mssql/provider.yaml | 3 +-
providers/microsoft/mssql/pyproject.toml | 6 +-
.../airflow/providers/microsoft/mssql/__init__.py | 2 +-
providers/openlineage/README.rst | 6 +-
providers/openlineage/docs/changelog.rst | 13 +
providers/openlineage/docs/index.rst | 6 +-
providers/openlineage/provider.yaml | 3 +-
providers/openlineage/pyproject.toml | 6 +-
.../src/airflow/providers/openlineage/__init__.py | 2 +-
.../airflow/providers/openlineage/api/datasets.py | 11 +-
.../src/airflow/providers/openlineage/api/sql.py | 9 +-
.../example_openlineage_all_facets_dag.py | 508 +++++++
...mple_openlineage_custom_operator_failure_dag.py | 88 ++
...e_openlineage_custom_operator_ol_methods_dag.py | 354 +++++
.../example_openlineage_defer_simple_dag.py | 4 +-
...g.py => example_openlineage_edge_labels_dag.py} | 30 +-
.../openlineage/example_openlineage_hitl_dag.py | 135 ++
.../example_openlineage_manual_lineage_dag.py | 255 ++++
...lineage_schedule_cron_trigger_timetable_dag.py} | 13 +-
...ineage_schedule_delta_trigger_timetable_dag.py} | 16 +-
...chedule_multiple_cron_trigger_timetable_dag.py} | 14 +-
... example_openlineage_schedule_timedelta_dag.py} | 14 +-
...y => example_openlineage_trigger_failed_dag.py} | 28 +-
.../system/openlineage/expected_events/__init__.py | 43 +-
.../openlineage_all_facets_dag.json | 842 +++++++++++
.../openlineage_custom_operator_failure_dag.json | 170 +++
...openlineage_custom_operator_ol_methods_dag.json | 434 ++++++
.../expected_events/openlineage_docs_file_dag.json | 24 +-
.../openlineage_edge_labels_dag.json | 72 +
.../expected_events/openlineage_hitl_dag.json | 353 +++++
.../openlineage_manual_lineage_dag.json | 1498 ++++++++++++++++++++
...penlineage_schedule_asset_or_time_dag__af3.json | 12 +-
...neage_schedule_cron_trigger_timetable_dag.json} | 18 +-
...eage_schedule_delta_trigger_timetable_dag.json} | 24 +-
...eage_schedule_list_complex_assets_dag__af3.json | 225 +--
...nlineage_schedule_multiple_assets_dag__af3.json | 12 +-
...hedule_multiple_cron_trigger_timetable_dag.json | 74 +
...> openlineage_schedule_timedelta_dag__af2.json} | 21 +-
...> openlineage_schedule_timedelta_dag__af3.json} | 24 +-
.../openlineage_task_groups_dag.json | 4 +-
...on => openlineage_trigger_dag__af3_3_plus.json} | 4 +-
...ineage_trigger_dag_deferrable__af3_3_plus.json} | 8 +-
...ag.json => openlineage_trigger_failed_dag.json} | 77 +-
...penlineage_trigger_failed_dag__af3_3_plus.json} | 81 +-
.../openlineage_versioned_dag__af3.json | 90 +-
.../tests/system/openlineage/operator.py | 94 +-
providers/opensearch/README.rst | 6 +-
providers/opensearch/docs/changelog.rst | 11 +
providers/opensearch/docs/index.rst | 6 +-
providers/opensearch/provider.yaml | 3 +-
providers/opensearch/pyproject.toml | 6 +-
.../src/airflow/providers/opensearch/__init__.py | 2 +-
.../papermill/docs/.latest-doc-only-change.txt | 2 +-
providers/postgres/README.rst | 6 +-
providers/postgres/docs/changelog.rst | 16 +
providers/postgres/docs/index.rst | 6 +-
providers/postgres/provider.yaml | 3 +-
providers/postgres/pyproject.toml | 6 +-
.../src/airflow/providers/postgres/__init__.py | 2 +-
providers/redis/README.rst | 6 +-
providers/redis/docs/changelog.rst | 11 +
providers/redis/docs/index.rst | 6 +-
providers/redis/provider.yaml | 3 +-
providers/redis/pyproject.toml | 6 +-
.../redis/src/airflow/providers/redis/__init__.py | 2 +-
providers/sftp/README.rst | 6 +-
providers/sftp/docs/changelog.rst | 11 +
providers/sftp/docs/index.rst | 6 +-
providers/sftp/provider.yaml | 3 +-
providers/sftp/pyproject.toml | 6 +-
.../sftp/src/airflow/providers/sftp/__init__.py | 2 +-
providers/slack/README.rst | 6 +-
providers/slack/docs/changelog.rst | 11 +
providers/slack/docs/index.rst | 6 +-
providers/slack/provider.yaml | 3 +-
providers/slack/pyproject.toml | 6 +-
.../slack/src/airflow/providers/slack/__init__.py | 2 +-
providers/smtp/docs/connections/smtp.rst | 2 +-
.../smtp/src/airflow/providers/smtp/hooks/smtp.py | 8 +-
providers/smtp/tests/unit/smtp/hooks/test_smtp.py | 43 +-
providers/snowflake/README.rst | 6 +-
providers/snowflake/docs/changelog.rst | 17 +
providers/snowflake/docs/index.rst | 6 +-
providers/snowflake/provider.yaml | 3 +-
providers/snowflake/pyproject.toml | 6 +-
.../src/airflow/providers/snowflake/__init__.py | 2 +-
providers/ssh/README.rst | 6 +-
providers/ssh/docs/changelog.rst | 12 +
providers/ssh/docs/index.rst | 6 +-
providers/ssh/provider.yaml | 3 +-
providers/ssh/pyproject.toml | 6 +-
.../ssh/src/airflow/providers/ssh/__init__.py | 2 +-
providers/standard/README.rst | 6 +-
providers/standard/docs/changelog.rst | 19 +
providers/standard/docs/index.rst | 6 +-
providers/standard/provider.yaml | 3 +-
providers/standard/pyproject.toml | 6 +-
.../src/airflow/providers/standard/__init__.py | 2 +-
providers/weaviate/README.rst | 6 +-
providers/weaviate/docs/changelog.rst | 11 +
providers/weaviate/docs/index.rst | 6 +-
providers/weaviate/provider.yaml | 4 +-
providers/weaviate/pyproject.toml | 6 +-
.../src/airflow/providers/weaviate/__init__.py | 2 +-
scripts/ci/prek/known_airflow_exceptions.txt | 2 +-
.../tests/listeners/test_listener_manager.py | 12 +-
.../observability/traces/__init__.py | 43 +-
.../tests/observability/test_traces.py | 103 ++
.../src/airflow/sdk/bases/resumablejobmixin.py | 18 +-
task-sdk/src/airflow/sdk/definitions/variable.py | 12 +-
task-sdk/src/airflow/sdk/types.py | 3 +
.../tests/task_sdk/bases/test_resumablejobmixin.py | 34 +
.../tests/task_sdk/definitions/test_variables.py | 17 +-
.../task_sdk/execution_time/test_task_runner.py | 18 +
uv.lock | 417 +++---
351 files changed, 12305 insertions(+), 1810 deletions(-)
create mode 100644
airflow-core/src/airflow/example_dags/example_task_state_store_mapped.py
create mode 100644
dev/breeze/doc/images/output_release-management_classify-provider-changes.svg
create mode 100644
dev/breeze/doc/images/output_release-management_classify-provider-changes.txt
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/durable/fingerprint.py
create mode 100644
providers/common/ai/src/airflow/providers/common/ai/utils/tool_definition.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_fingerprint.py
create mode 100644
providers/common/ai/tests/unit/common/ai/durable/test_replay_verification.py
copy
airflow-core/src/airflow/api_fastapi/auth/managers/simple/datamodels/login.py
=> providers/common/ai/tests/unit/common/ai/utils/test_tool_definition.py (59%)
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_all_facets_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_custom_operator_failure_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_custom_operator_ol_methods_dag.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_docs_file_dag.py
=> example_openlineage_edge_labels_dag.py} (52%)
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_hitl_dag.py
create mode 100644
providers/openlineage/tests/system/openlineage/example_openlineage_manual_lineage_dag.py
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_schedule_cron_dag.py
=> example_openlineage_schedule_cron_trigger_timetable_dag.py} (77%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_schedule_list_multiple_assets_dag.py
=> example_openlineage_schedule_delta_trigger_timetable_dag.py} (77%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_schedule_list_single_asset_dag.py
=> example_openlineage_schedule_multiple_cron_trigger_timetable_dag.py} (77%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_schedule_cron_dag.py
=> example_openlineage_schedule_timedelta_dag.py} (80%)
copy
providers/openlineage/tests/system/openlineage/{example_openlineage_trigger_dag.py
=> example_openlineage_trigger_failed_dag.py} (72%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_all_facets_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_custom_operator_failure_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_custom_operator_ol_methods_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_edge_labels_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_hitl_dag.json
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_manual_lineage_dag.json
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_schedule_cron_dag__af3.json
=> openlineage_schedule_cron_trigger_timetable_dag.json} (65%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_schedule_cron_dag__af2.json
=> openlineage_schedule_delta_trigger_timetable_dag.json} (55%)
create mode 100644
providers/openlineage/tests/system/openlineage/expected_events/openlineage_schedule_multiple_cron_trigger_timetable_dag.json
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_schedule_cron_dag__af2.json
=> openlineage_schedule_timedelta_dag__af2.json} (57%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_schedule_cron_dag__af3.json
=> openlineage_schedule_timedelta_dag__af3.json} (57%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_trigger_dag.json
=> openlineage_trigger_dag__af3_3_plus.json} (99%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_trigger_dag_deferrable.json
=> openlineage_trigger_dag_deferrable__af3_3_plus.json} (99%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_trigger_dag.json
=> openlineage_trigger_failed_dag.json} (86%)
copy
providers/openlineage/tests/system/openlineage/expected_events/{openlineage_trigger_dag.json
=> openlineage_trigger_failed_dag__af3_3_plus.json} (86%)
