Skip to content

Commit 0e627f3

Browse files
committed
Add support for DistributedNext
1 parent 11d491c commit 0e627f3

File tree

4 files changed

+45
-3
lines changed

4 files changed

+45
-3
lines changed

Manifest.toml

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
# This file is machine-generated - editing it directly is not advised
2+
3+
julia_version = "1.11.5"
4+
manifest_format = "2.0"
5+
project_hash = "3dde4276c4d0d1dd2649ad6d336bc098730409a9"
6+
7+
[[deps.Distributed]]
8+
deps = ["Random", "Serialization", "Sockets"]
9+
uuid = "8ba89e20-285c-5b6f-9357-94700520ee1b"
10+
version = "1.11.0"
11+
12+
[[deps.Random]]
13+
deps = ["SHA"]
14+
uuid = "9a3f8284-a2c9-5f02-9a11-845980a1fd5c"
15+
version = "1.11.0"
16+
17+
[[deps.SHA]]
18+
uuid = "ea8e919c-243c-51af-8825-aaa63cd721ce"
19+
version = "0.7.0"
20+
21+
[[deps.Serialization]]
22+
uuid = "9e88b42a-f829-5b0c-bbe9-9e923198166b"
23+
version = "1.11.0"
24+
25+
[[deps.Sockets]]
26+
uuid = "6462fe0b-24de-5631-8697-dd941f90decc"
27+
version = "1.11.0"

Project.toml

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,17 @@ version = "1.1.0"
66
[deps]
77
Distributed = "8ba89e20-285c-5b6f-9357-94700520ee1b"
88

9+
[weakdeps]
10+
DistributedNext = "fab6aee4-877b-4bac-a744-3eca44acbb6f"
11+
12+
[compat]
13+
Distributed = "< 0.0.1, 1"
14+
DistributedNext = "1"
15+
julia = "1.0"
16+
917
[extras]
18+
DistributedNext = "fab6aee4-877b-4bac-a744-3eca44acbb6f"
1019
Test = "8dfed614-e22c-5e08-85e1-65c5234f0b40"
1120

1221
[targets]
1322
test = ["Test"]
14-
15-
[compat]
16-
julia = "1.0"
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
import DistributedNext
2+
3+
function DistributedNext.launch(manager::SlurmManager, params::Dict, instances_arr::Array, c::Condition)
4+
return launch_slurm(manager, params, instances_arr::Array, c::Condition)
5+
end

src/slurmmanager.jl

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,10 @@ function warn_if_unexpected_params(params::Dict)
172172
end
173173

174174
function Distributed.launch(manager::SlurmManager, params::Dict, instances_arr::Array, c::Condition)
175+
return launch_slurm(manager, params, instances_arr::Array, c::Condition)
176+
end
177+
178+
function launch_slurm(manager::SlurmManager, params::Dict, instances_arr::Array, c::Condition)
175179
try
176180
warn_if_unexpected_params(params)
177181

0 commit comments

Comments
 (0)