updates to runner

Author: meggart

src/executionplan.jl

@@ -272,7 +272,7 @@ estimate_singleread(ia) = ia.ismem ? 1e-16 : 3.0
 function optimize_loopranges(op::GMDWop,max_cache;tol_low=0.2,tol_high = 0.05,max_order=2,x0 = nothing, force_regular=false)
   lb = [0.0,map(_->1.0,op.windowsize)...]
   ub = [max_cache,op.windowsize...]
-  x0 = x0 === nothing ? [2.0 for _ in op.windowsize] : x0
+  x0 = x0 === nothing ? [1.5 for _ in op.windowsize] : x0
   totsize = op.windowsize
   input_chunkspecs = get_chunkspec.(op.inars,(totsize,))
   output_chunkspecs = get_chunkspec.(op.outspecs,op.f.outtype)

src/runner.jl

@@ -168,21 +168,22 @@ function run_loop(runner::LocalRunner,loopranges = runner.loopranges;groupspecs=
     )
 end
 
-function default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter)
+function default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter, piddir)
     @debug "inow = ", inow
     if all(c -> need_run(inow, c), runfilter)
         inbuffers_wrapped = read_range.((inow,),op.inars,inbuffers_pure);
         outbuffers_now = extract_outbuffer.((inow,),op.outspecs,op.f.init,op.f.buftype,outbuffers)
         run_block(op,inow,inbuffers_wrapped,outbuffers_now,threaded)
-        put_buffer.((inow,),outbuffers_now,outars,nothing)
+        put_buffer.((inow,),outbuffers_now,outars,(piddir,))
         clean_aggregator.(outbuffers)
         notify_callback(cb, inow)
     end
+    true
 end
 
 @noinline function run_loop(::LocalRunner, op, inbuffers_pure, outbuffers, threaded, outars, loopranges, cb, runfilter; groupspecs=nothing)
     for inow in loopranges
-        default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter)
+        default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter,nothing)
     end
     notify_callback(cb, nothing)
 end
@@ -228,7 +229,7 @@ end
 
 @noinline function run_loop(::PMapRunner, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter, loopranges; groupspecs=nothing)
     pmap(CachingPool(workers()),loopranges) do inow
-        default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter)
+        default_loopbody(inow, op, inbuffers_pure, outbuffers, threaded, outars, cb, runfilter,nothing)
     end
     notify_callback(cb, nothing)
 end