Use package ElasticClusterManager, remove CustomClusterManagers

Improvements  in internal module CustomClusterManagers have been ported to
package ElasticClusterManager.

Author: oschulz

Project.toml

@@ -4,7 +4,7 @@ version = "0.4.7"
 
 [deps]
 ArgCheck = "dce04be8-c92d-5529-be00-80e4d2c0e197"
-ClusterManagers = "34f1f09b-3a8b-5176-ab39-66d58a4d544e"
+ElasticClusterManager = "547eee1f-27c8-4193-bfd6-9e092c8e3331"
 Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"
 LinearAlgebra = "37e2e46d-f89d-539d-b4ee-838fcccc9c8e"
 Logging = "56ddb016-857b-54e1-b83d-db4d58db5568"
@@ -21,7 +21,7 @@ ParallelProcessingToolsThreadPinningExt = "ThreadPinning"
 
 [compat]
 ArgCheck = "1, 2"
-ClusterManagers = "0.4.6, 1"
+ElasticClusterManager = "2"
 Distributed = "1"
 LinearAlgebra = "1"
 Logging = "1"

src/ParallelProcessingTools.jl

@@ -12,19 +12,18 @@ import Pkg
 import Random # Required by ThreadPinning extention
 import Sockets
 
-import ClusterManagers
-
 using Base: Process
 using Logging: @logmsg, LogLevel, Info, Debug
 
 using ArgCheck: @argcheck
 using Parameters: @with_kw
 
-# # ToDo: Remove CustomClusterManagers once changes to ElasticManager have
-# # have been upstreamed.
-#using CustomClusterManagers: ElasticManager
-include("custom_cluster_managers.jl")
-using .CustomClusterManagers: ElasticManager
+using ElasticClusterManager: ElasticManager, elastic_worker
+
+# For backward compatibility:
+module CustomClusterManagers
+    import ElasticClusterManager.ElasticManager
+end
 
 include("memory.jl")
 include("display.jl")

src/custom_cluster_managers.jl

@@ -141,7 +141,7 @@ function ppt_cluster_manager()
 end
 
 """
-    ParallelProcessingTools.ppt_cluster_manager!(manager::CustomClusterManagers.ElasticManager)
+    ParallelProcessingTools.ppt_cluster_manager!(manager::ElasticClusterManager.ElasticManager)
 
 Set the default ParallelProcessingTools cluster manager.
 """
@@ -260,7 +260,7 @@ function _elastic_worker_startjl(
     socket_name = manager.sockname
     address = string(socket_name[1])
     port = convert(Int, socket_name[2])
-    """import ParallelProcessingTools; ParallelProcessingTools.CustomClusterManagers.elastic_worker("$cookie", "$address", $port, stdout_to_master=$redirect_output, env=$env_vec)"""
+    """import ParallelProcessingTools; ParallelProcessingTools.elastic_worker("$cookie", "$address", $port, forward_stdout=$redirect_output, env=$env_vec)"""
 end
 
 const _default_addprocs_params = Distributed.default_addprocs_params()