@@ -863,10 +863,16 @@ await <- function(future, cleanup = TRUE, ...) {
863863 ))
864864 if (length(slurm_job_ids ) > 0 ) {
865865 info <- sprintf(" Slurm job ID: [n=%d] %s" , length(slurm_job_ids ), commaq(slurm_job_ids ))
866- args <- c(" --noheader" , " --format='job_id=%i,state=%T,submitted_on=%V,time_used=%M'" , " -j" , paste(slurm_job_ids , collapse = " ," ))
866+
867+ args <- c(" --noheader" , " --format='job_id=%i,state=%T,submitted_on=%V,time_used=%M'" , sprintf(" --jobs=%s" , paste(slurm_job_ids , collapse = " ," )))
867868 res <- system2(" squeue" , args = args , stdout = TRUE , stderr = TRUE )
868- res <- paste(res , collapse = " ; " ) # # should only be a single line, but ...
869- info <- c(info , sprintf(" Slurm job status: %s" , res ))
869+ res <- paste(res , collapse = " \n " )
870+ info <- c(info , sprintf(" Slurm 'squeue' job status:\n %s" , res ))
871+
872+ args <- c(" --noheader" , " --parsable2" , " --allocations" , " --format='JobID,State,ExitCode'" , sprintf(" --jobs=%s" , paste(slurm_job_ids , collapse = " ," )))
873+ res <- system2(" sacct" , args = args , stdout = TRUE , stderr = TRUE )
874+ res <- paste(res , collapse = " \n " )
875+ info <- c(info , sprintf(" Slurm 'sacct' job status:\n %s" , res ))
870876 } else {
871877 info <- " Slurm job ID: <not found>"
872878 info <- c(info , sprintf(" Slurm job status: <unknown>" ))
0 commit comments