Whitespace fixes (#235)

Author: DilumAluthge

Diff for: LICENSE.md

@@ -21,4 +21,3 @@ ClusterManagers.jl is licensed under the MIT License:
 > LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 > OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 > WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-

Diff for: README.md

@@ -93,7 +93,7 @@ julia>  From worker 2:  compute-6
         From worker 3:  compute-6
 ```
 
-Some clusters require the user to specify a list of required resources. 
+Some clusters require the user to specify a list of required resources.
 For example, it may be necessary to specify how much memory will be needed by the job - see this [issue](https://github.com/JuliaLang/julia/issues/10390).
 The keyword `qsub_flags` can be used to specify these and other options.
 Additionally the keyword `wd` can be used to specify the working directory (which defaults to `ENV["HOME"]`).
@@ -176,10 +176,10 @@ ElasticManager:
   Active workers : []
   Number of workers to be added  : 0
   Terminated workers : []
-  Worker connect command : 
+  Worker connect command :
     /home/user/bin/julia --project=/home/user/myproject/Project.toml -e 'using ClusterManagers; ClusterManagers.elastic_worker("4cOSyaYpgSl6BC0C","127.0.1.1",36275)'
 ```
 
-By default, the printed command uses the absolute path to the current Julia executable and activates the same project as the current session. You can change either of these defaults by passing `printing_kwargs=(absolute_exename=false, same_project=false))` to the first form of the `ElasticManager` constructor. 
+By default, the printed command uses the absolute path to the current Julia executable and activates the same project as the current session. You can change either of these defaults by passing `printing_kwargs=(absolute_exename=false, same_project=false))` to the first form of the `ElasticManager` constructor.
 
-Once workers are connected, you can print the `em` object again to see them added to the list of active workers. 
+Once workers are connected, you can print the `em` object again to see them added to the list of active workers.

Diff for: slurm_test.jl

@@ -16,6 +16,3 @@ ClusterManagers.addprocs_slurm(4; exeflags=["--project=.", "--color=yes"], job_f
     end
     end
 end
-
-
-

Diff for: src/affinity.jl

@@ -50,4 +50,3 @@ function manage(manager::LocalAffinityManager, id::Integer, config::WorkerConfig
         kill(get(config.process), 2)
     end
 end
-

Diff for: src/elastic.jl

@@ -26,7 +26,7 @@ struct ElasticManager <: ClusterManager
                 error("Failed to automatically get host's IP address. Please specify `addr=` explicitly.")
             end
         end
-        
+
         l_sock = listen(addr, port)
 
         lman = new(Dict{Int, WorkerConfig}(), Channel{TCPSocket}(typemax(Int)), Set{Int}(), topology, getsockname(l_sock), printing_kwargs)
@@ -125,7 +125,7 @@ function Base.show(io::IO, mgr::ElasticManager)
 
     println(iob, "  Worker connect command : ")
     print(iob, "    ", get_connect_cmd(mgr; mgr.printing_kwargs...))
-    
+
     print(io, String(take!(iob)))
 end
 
@@ -140,17 +140,17 @@ function elastic_worker(cookie, addr="127.0.0.1", port=9009; stdout_to_master=tr
 end
 
 function get_connect_cmd(em::ElasticManager; absolute_exename=true, same_project=true)
-    
+
     ip = string(em.sockname[1])
     port = convert(Int,em.sockname[2])
     cookie = cluster_cookie()
     exename = absolute_exename ? joinpath(Sys.BINDIR, Base.julia_exename()) : "julia"
     project = same_project ? ("--project=$(Pkg.API.Context().env.project_file)",) : ()
-    
+
     join([
         exename,
         project...,
         "-e 'using ClusterManagers; ClusterManagers.elastic_worker(\"$cookie\",\"$ip\",$port)'"
     ]," ")
-    
+
 end

Diff for: src/lsf.jl

@@ -40,21 +40,21 @@ function lsf_bpeek(manager::LSFManager, jobid, iarray)
     worker_started, bytestr, host, port = parse_host_port(stream)
     worker_started && return stream, host, port
 
-    for retry_delay in retry_delays 
-        # isempty is for the case when -f flag is not used to handle the case when 
+    for retry_delay in retry_delays
+        # isempty is for the case when -f flag is not used to handle the case when
         # the << output from ... >> message is printed but the julia worker has not
         # yet printed the ip and port nr
         if isempty(bytestr) || occursin("Not yet started", bytestr)
             # bpeek process would have stopped
-            # stream starts spewing out empty strings after this (in julia != 1.6) 
+            # stream starts spewing out empty strings after this (in julia != 1.6)
             # instead of trying to handle that we just close it and open a new stream
             wait(streamer_proc)
             close(stream)
             stream = Base.BufferStream()
 
             # Try bpeeking again after the retry delay
             sleep(retry_delay)
-            streamer_proc = run(pipeline(streamer_cmd; stdout=stream, stderr=stream); wait=false)                   
+            streamer_proc = run(pipeline(streamer_cmd; stdout=stream, stderr=stream); wait=false)
         elseif occursin("<< output from stdout >>", bytestr) || occursin("<< output from stderr >>", bytestr)
             # ignore this bpeek output decoration and continue to read the next line
             mark(stream)
@@ -63,7 +63,7 @@ function lsf_bpeek(manager::LSFManager, jobid, iarray)
             close(stream)
             throw(LSFException(bytestr))
         end
-        
+
         worker_started, bytestr, host, port = parse_host_port(stream)
         worker_started && break
     end
@@ -111,7 +111,7 @@ function launch(manager::LSFManager, params::Dict, launched::Array, c::Condition
         asyncmap((i)->lsf_launch_and_monitor(manager, launched, c, jobid, i),
                  1:np;
                  ntasks=manager.throttle)
- 
+
     catch e
         println("Error launching workers")
         println(e)

Diff for: src/qsub.jl

@@ -41,7 +41,7 @@ function launch(manager::Union{PBSManager, SGEManager, QRSHManager},
           for i in 1:np
               config = WorkerConfig()
               config.io, io_proc = stream_proc[i]
-              config.userdata = Dict{Symbol, Any}(:task => i, 
+              config.userdata = Dict{Symbol, Any}(:task => i,
                                                   :process => io_proc)
               push!(instances_arr, config)
               notify(c)

Diff for: test/runtests.jl

@@ -28,7 +28,7 @@ qsub_is_installed() = !isnothing(Sys.which("qsub"))
 
 @testset "ClusterManagers.jl" begin
     include("elastic.jl")
-    
+
     if slurm_is_installed()
         @info "Running the Slurm tests..." Sys.which("sbatch")
         include("slurm.jl")
@@ -41,7 +41,7 @@ qsub_is_installed() = !isnothing(Sys.which("qsub"))
             @test_skip false
         end
     end
-    
+
     if lsf_is_installed()
         @info "Running the LSF tests..." Sys.which("bsub")
         include("lsf.jl")
@@ -54,7 +54,7 @@ qsub_is_installed() = !isnothing(Sys.which("qsub"))
             @test_skip false
         end
     end
-    
+
     if qsub_is_installed()
         @info "Running the SGE (via qsub) tests..." Sys.which("qsub")
         include("slurm.jl")

Diff for: test/slurm.jl

@@ -10,7 +10,7 @@
             rmprocs(p)
             @test nprocs() == 1
             @test workers() == [1]
-            
+
             # Check that `outfile` exists:
             @test isfile(outfile)
             # Check that `outfile` is not empty: