Remove pids from collect_remote

JuliaParallel · Sep 30, 2020 · b8c5fb3 · b8c5fb3
1 parent 52be4e7
commit b8c5fb3
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/chunks.jl b/src/chunks.jl
@@ -65,13 +65,12 @@ function unrelease(c::Chunk{<:Any,DRef})
 end
 unrelease(c::Chunk) = c
 
-collect_remote(pids, chunk::Chunk) =
+collect_remote(chunk::Chunk) =
     move(chunk.processor, OSProc(), poolget(chunk.handle))
 function collect(ctx::Context, chunk::Chunk; options=nothing)
     # delegate fetching to handle by default.
     if chunk.handle isa DRef && !(chunk.processor isa OSProc)
-        pids = map(p -> p.pid, filter(p -> p isa OSProc, procs(ctx)))
-        return remotecall_fetch(collect_remote, chunk.handle.owner, pids, chunk)
+        return remotecall_fetch(collect_remote, chunk.handle.owner, chunk)
     elseif chunk.handle isa FileRef
         return poolget(chunk.handle)
     else