We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a4e8726 commit aa3241cCopy full SHA for aa3241c
nemo_run/core/execution/dgxcloud.py
@@ -405,7 +405,9 @@ def fetch_logs(
405
job_subdir = self.job_dir[len(nemo_run_home) + 1 :] # +1 to remove the initial backslash
406
self.pvc_job_dir = os.path.join(self.pvc_nemo_run_dir, job_subdir)
407
408
- while (files := len(glob.glob(f"{self.pvc_job_dir}/logs/output-*.log"))) < self.nodes:
+ files = []
409
+ while len(files) < self.nodes:
410
+ files = list(glob.glob(f"{self.pvc_job_dir}/logs/output-*.log"))
411
logger.info(f"Waiting for {self.nodes - len(files)} log files to be created...")
412
time.sleep(3)
413
0 commit comments