This is an automated email from the ASF dual-hosted git repository. kaxilnaik pushed a commit to branch v2-1-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit ccdc121383d1f3a75fce2a3a7db1d980e8e6d3bf Author: nmehraein <[email protected]> AuthorDate: Tue Aug 3 12:36:57 2021 +0200 Regression on pid reset to allow task start after heartbeat (#17333) Regression on PID reset to allow task start after heartbeat Co-authored-by: Nicolas MEHRAEIN <[email protected]> (cherry picked from commit ed99eaafc479aedbbe2d618da878195a132abb1a) --- airflow/models/taskinstance.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index c715f22..b492469 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -1030,6 +1030,7 @@ class TaskInstance(Base, LoggingMixin): self.refresh_from_db(session=session, lock_for_update=True) self.job_id = job_id self.hostname = get_hostname() + self.pid = None if not ignore_all_deps and not ignore_ti_state and self.state == State.SUCCESS: Stats.incr('previously_succeeded', 1, 1)
