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
