@@ -7,12 +7,11 @@ The environment variables `SLURM_JOB_ID` or `SLURM_JOBID` and `SLURM_NTASKS` mus
7
7
mutable struct SlurmManager <: ClusterManager
8
8
jobid:: Int
9
9
ntasks:: Int
10
- verbose:: Bool
11
10
launch_timeout:: Float64
12
11
srun_post_exit_sleep:: Float64
13
12
srun_proc
14
13
15
- function SlurmManager (;verbose = false , launch_timeout= 60.0 , srun_post_exit_sleep= 0.01 )
14
+ function SlurmManager (; launch_timeout= 60.0 , srun_post_exit_sleep= 0.01 )
16
15
17
16
jobid =
18
17
if " SLURM_JOB_ID" in keys (ENV )
@@ -39,7 +38,7 @@ mutable struct SlurmManager <: ClusterManager
39
38
jobid = parse (Int, jobid)
40
39
ntasks = parse (Int, ntasks)
41
40
42
- new (jobid, ntasks, verbose, launch_timeout, srun_post_exit_sleep, nothing )
41
+ new (jobid, ntasks, launch_timeout, srun_post_exit_sleep, nothing )
43
42
end
44
43
end
45
44
@@ -201,7 +200,7 @@ function Distributed.launch(manager::SlurmManager, params::Dict, instances_arr::
201
200
write (manager. srun_proc, " \n " )
202
201
203
202
t = @async for i in 1 : manager. ntasks
204
- manager . verbose && println ( " connecting to worker $i out of $(manager. ntasks) " )
203
+ @debug " connecting to worker $i out of $(manager. ntasks) "
205
204
206
205
line = readline (manager. srun_proc)
207
206
m = match (r" .*:(\d *)#(.*)" , line)
0 commit comments