diff --git a/inst/chunking/load_process_save_chunk.R b/inst/chunking/load_process_save_chunk.R index 7c1bc8a37947517538f60d6148e8e78c7072cf64..8a5843c31819ea3e3ba5e017b4faeedc20012e16 100644 --- a/inst/chunking/load_process_save_chunk.R +++ b/inst/chunking/load_process_save_chunk.R @@ -81,8 +81,8 @@ if (!is.null(attr(fun, 'UseLibraries'))) { require(attr(fun, 'UseLibraries')[i], character.only = TRUE) } } -chunk_indices <- setNames(as.integer(chunk_indices), names(chunk_indices)) -chunk_indices <- chunk_indices[names(chunks)[which(chunks > 1)]] +chunk_indices_apply <- setNames(as.integer(chunk_indices), names(chunk_indices)) +chunk_indices_apply <- chunk_indices_apply[names(chunks)[which(chunks > 1)]] Apply <- multiApply::Apply res <- do.call("Apply", c( @@ -91,7 +91,7 @@ res <- do.call("Apply", fun = fun, output_dims = attr(fun, 'OutputDims'), use_attributes = attr(fun, 'UseAttributes'), - extra_info = list(chunk_indices = chunk_indices), + extra_info = list(chunk_indices = chunk_indices_apply), ncores = threads_compute), params )