[airflow] branch main updated: Small docstring clarification in _find_zombies (#24930)

[ds...@apache.org]

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 <15...@users.noreply.github.com>
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)