diff --git a/R/read_households.R b/R/read_households.R
index 057c1d0..8de7157 100644
--- a/R/read_households.R
+++ b/R/read_households.R
@@ -56,7 +56,7 @@ read_households <- function(year = 2010,
   if(is.null(local_file)) { return(invisible(NULL)) }
 
   ### read data
-  df <- arrow_open_dataset(local_file)
+  df <- duckplyr::read_parquet_duckdb(local_file)
 
   ### Select
   if (!is.null(columns)) { # columns <- c('V0002','V0011')
diff --git a/R/read_population.R b/R/read_population.R
index 0f33880..2e1901a 100644
--- a/R/read_population.R
+++ b/R/read_population.R
@@ -57,7 +57,7 @@ read_population <- function(year = 2010,
   if(is.null(local_file)) { return(invisible(NULL)) }
 
   ### read data
-  df <- arrow_open_dataset(local_file)
+  df <- duckplyr::read_parquet_duckdb(local_file)
 
   # ### merge household data
   # if (isTRUE(merge_households)) {