TEMP: Disable chunk cache

JuliaParallel · Dec 7, 2023 · dfec8ab · dfec8ab
1 parent 72661b9
commit dfec8ab
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/sch/Sch.jl b/src/sch/Sch.jl
@@ -1472,6 +1472,7 @@ function do_task(to_proc, task_desc)
     fetch_tasks = map(Iterators.zip(_data,_ids)) do (x, id)
         @async begin
             timespan_start(ctx, :move, (;thunk_id, id), (;f, id, data=x))
+            #=
             x = if x isa Chunk
                 value = lock(TASK_SYNC) do
                     if haskey(CHUNK_CACHE, x)
@@ -1512,8 +1513,9 @@ function do_task(to_proc, task_desc)
                     _x
                 end
             else
-                @invokelatest move(to_proc, x)
-            end
+            =#
+            x = @invokelatest move(to_proc, x)
+            #end
             @dagdebug thunk_id :move "Moved argument $id to $to_proc: $x"
             timespan_finish(ctx, :move, (;thunk_id, id), (;f, id, data=x); tasks=[Base.current_task()])
             return x