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/15 13:18:56 UTC

[airflow] branch main updated (2a6792d -> 7be87d8)

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 2a6792d  Fix race condition between triggerer and scheduler (#21316)
     add 7be87d8  Type TaskInstance.task to Operator and call unmap() when needed (#21563)

No new revisions were added by this update.

Summary of changes:
 airflow/cli/commands/task_command.py               |  8 +++---
 airflow/dag_processing/processor.py                |  2 +-
 airflow/decorators/base.py                         |  3 ++-
 airflow/executors/debug_executor.py                |  3 +--
 airflow/jobs/local_task_job.py                     |  3 +--
 airflow/models/baseoperator.py                     | 27 ++++++++++++-------
 airflow/models/dagrun.py                           |  2 +-
 airflow/models/mappedoperator.py                   |  5 ++++
 airflow/models/taskinstance.py                     | 31 ++++++++++------------
 .../providers/elasticsearch/log/es_task_handler.py |  4 ++-
 airflow/utils/log/file_task_handler.py             |  4 ++-
 airflow/www/views.py                               |  4 +--
 12 files changed, 55 insertions(+), 41 deletions(-)