···396396 | FunctionDefinition (name, (body, _rdrs)) :: rest ->
397397 let ctx = { ctx with functions = (name, body) :: ctx.functions } in
398398 loop ctx job (pgid, None) rest
399399- | [] -> (ctx, job)
399399+ | [] -> (clear_local_state ctx, job)
400400 in
401401 (* HACK: when running the pipeline, we need a process group to
402402 put everything in. Eio's model of execution is nice, but we cannot