You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by ur...@apache.org on 2022/02/11 18:39:39 UTC
[airflow] branch main updated (84ab861 -> 0cd3b11)
This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git.
from 84ab861 Only adds MySQL apt sources once (#21519)
add 0cd3b11 Straighten up MappedOperator hierarchy and typing (#21505)
No new revisions were added by this update.
Summary of changes:
UPDATING.md | 4 +
airflow/api/common/mark_tasks.py | 5 +-
airflow/api_connexion/schemas/common_schema.py | 5 +-
airflow/api_connexion/schemas/task_schema.py | 4 +-
airflow/dag_processing/processor.py | 2 +-
airflow/decorators/base.py | 102 ++-
airflow/decorators/python.py | 20 +-
airflow/decorators/python_virtualenv.py | 19 +-
airflow/jobs/backfill_job.py | 4 +-
airflow/jobs/local_task_job.py | 8 +-
airflow/jobs/scheduler_job.py | 2 +-
airflow/lineage/__init__.py | 8 +-
airflow/models/__init__.py | 38 +-
airflow/models/{base.py => abstractoperator.py} | 155 +++--
airflow/models/base.py | 129 +---
airflow/models/baseoperator.py | 772 ++++++---------------
airflow/models/dag.py | 33 +-
airflow/models/dagrun.py | 11 +-
airflow/models/mappedoperator.py | 498 +++++++++++++
.../models/operator.py | 11 +-
airflow/models/skipmixin.py | 1 +
airflow/models/taskinstance.py | 25 +-
airflow/models/taskmixin.py | 8 +-
airflow/models/xcom_arg.py | 6 +-
airflow/serialization/serialized_objects.py | 90 ++-
airflow/timetables/base.py | 2 +-
airflow/utils/helpers.py | 4 +-
tests/dags/test_mapped_classic.py | 2 +-
tests/decorators/test_python.py | 19 +-
tests/models/test_baseoperator.py | 41 +-
tests/serialization/test_dag_serialization.py | 55 +-
tests/utils/test_helpers.py | 12 +-
tests/utils/test_task_group.py | 2 +-
33 files changed, 1168 insertions(+), 929 deletions(-)
copy airflow/models/{base.py => abstractoperator.py} (51%)
create mode 100644 airflow/models/mappedoperator.py
copy tests/listeners/partial_listener.py => airflow/models/operator.py (79%)