Fix missing callback application

ratschlab · Mar 25, 2024 · 84ec51f · 84ec51f
1 parent 74a66d9
commit 84ec51f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/R/setup-import.R b/R/setup-import.R
@@ -229,7 +229,9 @@ merge_fst_chunks <- function(src, targ, new, old, sort_col, prog, nme, tick) {
 split_write <- function(x, part_fun, dir, chunk_no, prog, nme, tick, callback = NULL) {
 
   n_row <- nrow(x)
-
+  if (!is.null(callback)) {
+    x <- callback(x)
+  }
   x <- split(x, part_fun(x))
 
   tmp_nme <- file.path(dir, paste0("part_", names(x)),