This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch backport-486f836-v3-4-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
from af75c2d02e7 [v3-4-test] Pass runtime values to example Dag shell
commands through env (#73787)
add 81dad40784d [v3-4-test] Run the lang-SDK conformance serializer in its
own virtualenv (#75085) (#75111)
add 6fd6f6bdf65 [v3-4-test] Add the resume event to stored next_kwargs
without decoding them (#73576) (#75116)
add 10fded35a70 [v3-4-test] Only rebuild built-in value types when
converting next_kwargs for older workers (#73577) (#75115)
add 0624e836524 [v3-4-test] Mask XCom values in the audit log (#73791)
(#75113)
add 43b674c1309 [v3-4-test] Mask registered secrets at any nesting depth
(#73793) (#75112)
add b623bc6e6cd [v3-4-test] Scope asset Dag and task references to
readable Dags (#74836) (#75107)
add a037e9f2b7c [v3-4-test] Mask provider-declared sensitive connection
extras on every connection type (#73794) (#75106)
add 7720bb0659e [v3-4-test] Reject reserved serialization keys in Dag run
conf (#74834) (#75105)
add 7a58718f493 [v3-4-test] Validate CallbackTrigger callback path before
running the callback (#74842) (#75102)
add 22e19283d33 [v3-4-test] Read XCom without object reconstruction during
dependency evaluation (#72718) (#75117)
add 88801da4987 [v3-4-test] Decode deadline callback kwargs where the
callback runs (#74830) (#75114)
add d91836c0135 Merge branch 'v3-4-test' into backport-486f836-v3-4-test
No new revisions were added by this update.
Summary of changes:
airflow-core/newsfragments/73577.significant.rst | 5 +
airflow-core/newsfragments/73791.improvement.rst | 1 +
airflow-core/newsfragments/73793.improvement.rst | 1 +
airflow-core/newsfragments/73794.improvement.rst | 1 +
airflow-core/newsfragments/74830.significant.rst | 10 +
airflow-core/newsfragments/74834.bugfix.rst | 1 +
airflow-core/newsfragments/74836.bugfix.rst | 1 +
airflow-core/newsfragments/74842.improvement.rst | 1 +
.../api_fastapi/core_api/datamodels/assets.py | 19 +-
.../api_fastapi/core_api/datamodels/backfills.py | 8 +-
.../api_fastapi/core_api/datamodels/common.py | 14 +
.../api_fastapi/core_api/datamodels/connections.py | 57 ++++
.../api_fastapi/core_api/datamodels/dag_run.py | 8 +-
.../api_fastapi/core_api/routes/public/assets.py | 59 ++--
.../api_fastapi/core_api/routes/ui/assets.py | 9 +-
.../core_api/services/public/connections.py | 12 +-
.../api_fastapi/execution_api/datamodels/dagrun.py | 8 +-
.../execution_api/versions/v2026_04_06.py | 224 +++++++++++++-
.../src/airflow/api_fastapi/logging/decorators.py | 16 +
.../src/airflow/executors/base_executor.py | 8 +
.../src/airflow/executors/workloads/callback.py | 6 +
.../src/airflow/jobs/triggerer_job_runner.py | 6 +-
airflow-core/src/airflow/models/callback.py | 52 +++-
airflow-core/src/airflow/models/deadline.py | 33 +-
airflow-core/src/airflow/models/taskinstance.py | 19 +-
airflow-core/src/airflow/models/trigger.py | 90 ++++--
airflow-core/src/airflow/models/xcom.py | 43 +++
airflow-core/src/airflow/serialization/decoders.py | 89 +++++-
airflow-core/src/airflow/serialization/encoders.py | 68 ++++-
.../ti_deps/deps/not_previously_skipped_dep.py | 66 +++-
.../src/airflow/ti_deps/deps/prev_dagrun_dep.py | 14 +
.../src/airflow/ti_deps/deps/trigger_rule_dep.py | 12 +-
airflow-core/src/airflow/triggers/callback.py | 27 ++
.../core_api/datamodels/test_connections.py | 60 ++++
.../core_api/datamodels/test_dag_run.py | 66 +++-
.../core_api/routes/public/test_assets.py | 108 ++++++-
.../core_api/routes/public/test_backfills.py | 27 ++
.../core_api/routes/public/test_connections.py | 133 ++++++++
.../core_api/routes/public/test_dag_run.py | 25 ++
.../core_api/routes/public/test_xcom.py | 41 +++
.../api_fastapi/core_api/routes/ui/test_assets.py | 42 ++-
.../execution_api/versions/head/test_dag_runs.py | 21 ++
.../versions/v2026_04_06/test_task_instances.py | 339 +++++++++++++++++++++
.../unit/api_fastapi/logging/test_decorators.py | 15 +
.../tests/unit/executors/test_local_executor.py | 23 ++
airflow-core/tests/unit/jobs/test_scheduler_job.py | 59 ++++
airflow-core/tests/unit/jobs/test_triggerer_job.py | 41 +++
airflow-core/tests/unit/models/test_callback.py | 200 +++++++++++-
airflow-core/tests/unit/models/test_deadline.py | 167 +++++++++-
airflow-core/tests/unit/models/test_trigger.py | 70 +++++
airflow-core/tests/unit/models/test_xcom.py | 90 ++++++
.../unit/serialization/test_serialized_objects.py | 86 +++++-
.../deps/test_not_previously_skipped_dep.py | 311 +++++++++++++++++++
.../unit/ti_deps/deps/test_trigger_rule_dep.py | 62 +++-
airflow-core/tests/unit/triggers/test_callback.py | 114 ++++++-
.../src/tests_common/test_utils/mock_context.py | 1 +
generated/known_sdk_imports_in_core.txt | 4 +-
scripts/ci/lang_sdk_serialization/compare.py | 13 +-
.../secrets_masker/secrets_masker.py | 15 +-
.../tests/secrets_masker/test_secrets_masker.py | 11 +-
.../sdk/execution_time/callback_supervisor.py | 29 ++
.../execution_time/test_callback_supervisor.py | 107 ++++++-
62 files changed, 3083 insertions(+), 185 deletions(-)
create mode 100644 airflow-core/newsfragments/73577.significant.rst
create mode 100644 airflow-core/newsfragments/73791.improvement.rst
create mode 100644 airflow-core/newsfragments/73793.improvement.rst
create mode 100644 airflow-core/newsfragments/73794.improvement.rst
create mode 100644 airflow-core/newsfragments/74830.significant.rst
create mode 100644 airflow-core/newsfragments/74834.bugfix.rst
create mode 100644 airflow-core/newsfragments/74836.bugfix.rst
create mode 100644 airflow-core/newsfragments/74842.improvement.rst
