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