Skip to content

Commit 33b2cd8

Browse files
authored
Small docstring clarification in _find_zombies (apache#24930)
1 parent 3f9414d commit 33b2cd8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airflow/jobs/scheduler_job.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1358,8 +1358,8 @@ def check_trigger_timeouts(self, session: Session = None):
13581358
def _find_zombies(self, session):
13591359
"""
13601360
Find zombie task instances, which are tasks haven't heartbeated for too long
1361-
or have a no-longer-running LocalTaskJob, and send them off to the DAG processor
1362-
to be handled.
1361+
or have a no-longer-running LocalTaskJob, and create a TaskCallbackRequest
1362+
to be handled by the DAG processor.
13631363
"""
13641364
self.log.debug("Finding 'running' jobs without a recent heartbeat")
13651365
limit_dttm = timezone.utcnow() - timedelta(seconds=self._zombie_threshold_secs)

0 commit comments

Comments
 (0)