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 e2220d738e3 Added validation for consumed_asset_event for
DagRunContext. Unit tests included. (#59857)
add b8e431ff071 PartitionMapper, IdentityMapper, PartitionedAssetTimetable
- core / task-sdk separation (#60204)
No new revisions were added by this update.
Summary of changes:
.../{_shared => partition_mapper}/__init__.py | 0
.../src/airflow/partition_mapper/base.py | 32 +++++---
.../src/airflow/partition_mapper/identity.py | 18 +++--
airflow-core/src/airflow/serialization/decoders.py | 23 +++++-
airflow-core/src/airflow/serialization/encoders.py | 90 +++++++++++++++++-----
airflow-core/src/airflow/serialization/helpers.py | 31 +++++++-
.../airflow/serialization/serialized_objects.py | 53 +------------
airflow-core/src/airflow/timetables/simple.py | 44 ++---------
airflow-core/tests/unit/jobs/test_scheduler_job.py | 3 +-
.../tests/unit/models/test_taskinstance.py | 14 +++-
.../unit/serialization/test_serialized_objects.py | 40 ++++++++++
.../tests/unit/timetables/test_assets_timetable.py | 2 +-
task-sdk/docs/api.rst | 7 ++
task-sdk/src/airflow/sdk/__init__.py | 13 +++-
task-sdk/src/airflow/sdk/__init__.pyi | 10 ++-
.../sdk/definitions/partition_mapper}/__init__.py | 0
.../sdk/definitions/partition_mapper/base.py | 9 ++-
.../sdk/definitions/partition_mapper/identity.py | 7 +-
.../airflow/sdk/definitions/timetables/assets.py | 13 +++-
19 files changed, 263 insertions(+), 146 deletions(-)
copy airflow-core/src/airflow/{_shared => partition_mapper}/__init__.py (100%)
copy providers/fab/src/airflow/providers/fab/www/airflow_flask_app.py =>
airflow-core/src/airflow/partition_mapper/base.py (56%)
copy
providers/common/compat/src/airflow/providers/common/compat/notifier/__init__.py
=> airflow-core/src/airflow/partition_mapper/identity.py (72%)
copy {airflow-core/src/airflow/_shared =>
task-sdk/src/airflow/sdk/definitions/partition_mapper}/__init__.py (100%)
copy airflow-core/src/airflow/models/skipmixin.py =>
task-sdk/src/airflow/sdk/definitions/partition_mapper/base.py (85%)
copy airflow-core/src/airflow/models/skipmixin.py =>
task-sdk/src/airflow/sdk/definitions/partition_mapper/identity.py (82%)
