You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2023/01/03 09:11:05 UTC

[airflow] branch main updated (8da678ccd2 -> 25e0e30099)

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


    from 8da678ccd2 Ensure Beam Go file downloaded from GCS still exists when referenced (#28664)
     add 25e0e30099 add a new conf to wait past_deps before skipping a task (#27710)

No new revisions were added by this update.

Summary of changes:
 airflow/cli/cli_parser.py                          |  6 +-
 airflow/cli/commands/task_command.py               |  2 +
 airflow/executors/base_executor.py                 |  2 +
 airflow/executors/celery_kubernetes_executor.py    | 20 +++---
 airflow/executors/debug_executor.py                |  1 +
 airflow/executors/local_kubernetes_executor.py     | 20 +++---
 airflow/jobs/backfill_job.py                       |  2 +
 airflow/jobs/local_task_job.py                     |  3 +
 airflow/models/abstractoperator.py                 |  1 +
 airflow/models/baseoperator.py                     | 10 +++
 airflow/models/mappedoperator.py                   |  8 +++
 airflow/models/taskinstance.py                     | 15 ++++
 airflow/serialization/schema.json                  |  1 +
 airflow/ti_deps/dep_context.py                     |  2 +
 airflow/ti_deps/deps/not_previously_skipped_dep.py | 10 +++
 airflow/ti_deps/deps/prev_dagrun_dep.py            | 16 ++++-
 airflow/ti_deps/deps/trigger_rule_dep.py           | 40 +++++++----
 tests/cli/commands/test_task_command.py            |  3 +
 tests/executors/test_celery_kubernetes_executor.py |  6 +-
 tests/serialization/test_dag_serialization.py      |  1 +
 tests/ti_deps/deps/test_prev_dagrun_dep.py         | 82 ++++++++++++++++++++--
 tests/ti_deps/deps/test_trigger_rule_dep.py        | 66 +++++++++++++++++
 22 files changed, 276 insertions(+), 41 deletions(-)