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%)