Run the pipeline on all files in a directory — run_pipeline

Applies run_pipeline() to every file matching pattern in folder, returning a list of zeitr_result objects. Files that fail are skipped with a warning.

Usage

run_pipeline_batch(folder, pattern = "*.txt", parallel = FALSE, ...)

Arguments

folder: character(1). Path to a directory containing ActTrust files.
pattern: character(1). Glob pattern for file discovery. Default is "*.txt".
parallel: logical(1). If TRUE, processes files in parallel using future.apply::future_lapply() (a Suggests-only dependency). Requires a future::plan() to be set beforehand, e.g. future::plan(future::multisession(workers = 4)); falls back to sequential processing with a warning if future.apply is not installed. Default FALSE.
...: Additional arguments forwarded to run_pipeline().

Value

A named list of zeitr_result objects, one per successfully processed file. Names are the file stem (subject IDs).

Examples

if (FALSE) { # \dontrun{
results <- run_pipeline_batch("recordings/", tz = "America/Sao_Paulo")
lapply(results, function(r) r$nights)

# Parallel: process a large cohort across 4 workers
future::plan(future::multisession(workers = 4))
results <- run_pipeline_batch("recordings/", tz = "America/Sao_Paulo",
                               parallel = TRUE)
} # }