Add debug logs to cluster_master _monitor_job_result to check progress extension

parent 62f80486
......@@ -817,7 +817,11 @@ class ClusterMaster:
# Check if we have recent progress to extend timeout
from .database import get_queue_by_job_id
job = get_queue_by_job_id(job_id)
print(f"DEBUG: job_id = {job_id}, job = {job}")
if job:
print(f"DEBUG: progress = {job.get('progress', 0)}")
if job and job.get('progress', 0) > 0:
print(f"DEBUG: extending timeout, has_progress = {has_progress}")
has_progress = True
last_progress_time = time.time()
# Extend timeout when progress is active
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment