Skip to content

Commit

Permalink
print scheduler we submit to
Browse files Browse the repository at this point in the history
  • Loading branch information
mschubert committed Aug 7, 2024
1 parent 9feec60 commit b8850ae
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 3 deletions.
3 changes: 2 additions & 1 deletion R/qsys_lsf.r
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ LSF = R6::R6Class("LSF",
required=c("master", "job_name", "n_jobs"))

if (verbose)
message("Submitting ", n_jobs, " worker jobs (ID: ", private$job_id, ") ...")
message("Submitting ", n_jobs, " worker jobs to ", class(self)[1],
" (ID: ", private$job_id, ") ...")

status = system("bsub", input=filled, ignore.stdout=TRUE)
if (status != 0)
Expand Down
3 changes: 2 additions & 1 deletion R/qsys_sge.r
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ SGE = R6::R6Class("SGE",
filled = fill_template(private$template, opts, required=c("master", "n_jobs"))

if (verbose)
message("Submitting ", n_jobs, " worker jobs (ID: ", private$job_name, ") ...")
message("Submitting ", n_jobs, " worker jobs to ", class(self)[1],
" (ID: ", private$job_id, ") ...")

private$qsub_stdout = system2("qsub", input=filled, stdout=TRUE)
status = attr(private$qsub_stdout, "status")
Expand Down
3 changes: 2 additions & 1 deletion R/qsys_slurm.r
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,8 @@ SLURM = R6::R6Class("SLURM",
required=c("master", "job_name", "n_jobs"))

if (verbose)
message("Submitting ", n_jobs, " worker jobs (ID: ", private$job_id, ") ...")
message("Submitting ", n_jobs, " worker jobs to ", class(self)[1],
" (ID: ", private$job_id, ") ...")

status = system("sbatch", input=filled, ignore.stdout=TRUE)
if (status != 0)
Expand Down

0 comments on commit b8850ae

Please sign in to comment.