pragnareddye commented on code in PR #32313:
URL: https://github.com/apache/airflow/pull/32313#discussion_r1252491395
##########
airflow/jobs/local_task_job_runner.py:
##########
@@ -158,7 +158,7 @@ def sigusr2_debug_handler(signum, frame):
try:
self.task_runner.start()
- heartbeat_time_limit = conf.getint("scheduler",
"scheduler_zombie_task_threshold")
+ heartbeat_time_limit = conf.getint("scheduler",
"local_task_job_heartbeat_sec")
Review Comment:
Hey Ephraim! For us atleast, when we are running our jobs, we have these
default values set and having these default values set differently for
different job types is very convenient for us. Anyways the idea of this is also
coming from https://github.com/apache/airflow/issues/30908. Definitely open to
discuss however
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
