Skip to content

Commit e936d91

Browse files
authored
Merge pull request #353 from JuliaParallel/jps/fix-chunk-cache-some
Sch: Fix Some{Any} in CHUNK_CACHE
2 parents 048f729 + 73b7180 commit e936d91

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/sch/Sch.jl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1054,13 +1054,13 @@ function do_task(to_proc, comm)
10541054
x = if x isa Chunk
10551055
value = lock(TASK_SYNC) do
10561056
if haskey(CHUNK_CACHE, x)
1057-
get!(CHUNK_CACHE[x], to_proc) do
1057+
Some{Any}(get!(CHUNK_CACHE[x], to_proc) do
10581058
# Convert from cached value
10591059
# TODO: Choose "closest" processor of same type first
10601060
some_proc = first(keys(CHUNK_CACHE[x]))
10611061
some_x = CHUNK_CACHE[x][some_proc]
1062-
Some{Any}(move(some_proc, to_proc, some_x))
1063-
end
1062+
move(some_proc, to_proc, some_x)
1063+
end)
10641064
else
10651065
nothing
10661066
end

0 commit comments

Comments
 (0)