This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a change to branch bound-heartbeat-purge-batch
in repository https://gitbox.apache.org/repos/asf/airflow.git
from adde1bd2fea Bound the heartbeat-timeout purge to max_tis_per_query per
loop
add 72d216cec55 Address review: reschedule on full batch, bound by
parallelism, fail unresolvable TIs
No new revisions were added by this update.
Summary of changes:
.../src/airflow/config_templates/config.yml | 7 +-
.../src/airflow/jobs/scheduler_job_runner.py | 59 +++++++++++------
airflow-core/src/airflow/utils/event_scheduler.py | 14 +++-
airflow-core/tests/unit/jobs/test_scheduler_job.py | 77 ++++++++++++++++++++++
.../tests/unit/utils/test_event_scheduler.py | 30 +++++++++
5 files changed, 163 insertions(+), 24 deletions(-)
