We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 967650d commit 420abd3Copy full SHA for 420abd3
src/datastore.jl
@@ -87,9 +87,11 @@ function get_wrkrips()
87
end
88
89
get_worker_at(ip::String) = get_worker_at(IPv4(ip))
90
-function get_worker_at(ip::IPv4)
+get_worker_at(ip::IPv4) = rand(get_workers_at(ip))
91
+
92
+function get_workers_at(ip::IPv4)
93
isempty(wrkrips) && merge!(wrkrips, remotecall_fetch(get_wrkrips, 1))
- rand(wrkrips[ip]) # rand is equivalent to first when length(wrkrids) == 1
94
+ wrkrips[ip]
95
96
97
function poolget(r::FileRef)
0 commit comments