This is an automated email from the ASF dual-hosted git repository.
dstandish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 33b2cd8784 Small docstring clarification in _find_zombies (#24930)
33b2cd8784 is described below
commit 33b2cd8784dcbc626f79e2df432ad979727c9a08
Author: Daniel Standish <[email protected]>
AuthorDate: Fri Jul 8 14:45:54 2022 -0700
Small docstring clarification in _find_zombies (#24930)
---
airflow/jobs/scheduler_job.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/airflow/jobs/scheduler_job.py b/airflow/jobs/scheduler_job.py
index 39aac294a8..338ceedf8a 100644
--- a/airflow/jobs/scheduler_job.py
+++ b/airflow/jobs/scheduler_job.py
@@ -1358,8 +1358,8 @@ class SchedulerJob(BaseJob):
def _find_zombies(self, session):
"""
Find zombie task instances, which are tasks haven't heartbeated for
too long
- or have a no-longer-running LocalTaskJob, and send them off to the DAG
processor
- to be handled.
+ or have a no-longer-running LocalTaskJob, and create a
TaskCallbackRequest
+ to be handled by the DAG processor.
"""
self.log.debug("Finding 'running' jobs without a recent heartbeat")
limit_dttm = timezone.utcnow() -
timedelta(seconds=self._zombie_threshold_secs)
