You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by we...@apache.org on 2026/02/17 08:13:39 UTC
(airflow) branch main updated (9880716dc07 -> 8064eb91d02)
This is an automated email from the ASF dual-hosted git repository.
weilee pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 9880716dc07 Fix scheduler heartbeat misses caused by slow reschedule dependency check (#61983)
add 8064eb91d02 Add temporal for partition_mappers (#61522)
No new revisions were added by this update.
Summary of changes:
.../__init__.py | 0
.../base.py | 0
.../identity.py | 3 +-
.../src/airflow/partition_mappers/temporal.py | 144 +++++++++++++++++++++
airflow-core/src/airflow/plugins_manager.py | 2 +-
airflow-core/src/airflow/serialization/decoders.py | 2 +-
airflow-core/src/airflow/serialization/encoders.py | 36 +++++-
airflow-core/src/airflow/serialization/helpers.py | 4 +-
airflow-core/src/airflow/timetables/simple.py | 2 +-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 2 +-
.../unit/partition_mappers}/__init__.py | 0
.../unit/partition_mappers/test_identity.py} | 18 +--
.../tests/unit/partition_mappers/test_temporal.py | 83 ++++++++++++
.../unit/serialization/test_serialized_objects.py | 92 +++++++++++--
.../tests/test_pytest_args_for_test_types.py | 1 +
scripts/ci/prek/check_tests_in_right_folders.py | 1 +
task-sdk/docs/api.rst | 21 ++-
task-sdk/src/airflow/sdk/__init__.py | 28 +++-
task-sdk/src/airflow/sdk/__init__.pyi | 18 ++-
.../sdk/definitions/partition_mapper/__init__.py | 16 ---
.../sdk/definitions/partition_mappers}/__init__.py | 0
.../base.py | 0
.../identity.py | 6 +-
.../sdk/definitions/partition_mappers/temporal.py | 67 ++++++++++
.../airflow/sdk/definitions/timetables/assets.py | 2 +-
25 files changed, 491 insertions(+), 57 deletions(-)
rename airflow-core/src/airflow/{partition_mapper => partition_mappers}/__init__.py (100%)
rename airflow-core/src/airflow/{partition_mapper => partition_mappers}/base.py (100%)
rename airflow-core/src/airflow/{partition_mapper => partition_mappers}/identity.py (94%)
create mode 100644 airflow-core/src/airflow/partition_mappers/temporal.py
copy airflow-core/{src/airflow/_shared => tests/unit/partition_mappers}/__init__.py (100%)
copy airflow-core/{src/airflow/api_fastapi/core_api/datamodels/extra_links.py => tests/unit/partition_mappers/test_identity.py} (67%)
create mode 100644 airflow-core/tests/unit/partition_mappers/test_temporal.py
delete mode 100644 task-sdk/src/airflow/sdk/definitions/partition_mapper/__init__.py
copy {airflow-core/src/airflow/_shared => task-sdk/src/airflow/sdk/definitions/partition_mappers}/__init__.py (100%)
rename task-sdk/src/airflow/sdk/definitions/{partition_mapper => partition_mappers}/base.py (100%)
rename task-sdk/src/airflow/sdk/definitions/{partition_mapper => partition_mappers}/identity.py (86%)
create mode 100644 task-sdk/src/airflow/sdk/definitions/partition_mappers/temporal.py