Fix ##1429

DESCRIPTION

@@ -12,7 +12,7 @@ Description: Pipeline tools coordinate the pieces of computationally
   The methodology in this package
   borrows from GNU 'Make' (2015, ISBN:978-9881443519)
   and 'drake' (2018, <doi:10.21105/joss.00550>).
-Version: 1.10.1.9003
+Version: 1.10.1.9004
 License: MIT + file LICENSE
 URL: https://docs.ropensci.org/targets/, https://github.com/ropensci/targets
 BugReports: https://github.com/ropensci/targets/issues

NAMESPACE

@@ -174,6 +174,7 @@ S3method(store_read_object,tar_gcp)
 S3method(store_read_object,tar_gcp_file)
 S3method(store_read_object,tar_repository_cas)
 S3method(store_read_object,tar_repository_cas_file)
+S3method(store_read_path,tar_auto)
 S3method(store_read_path,tar_feather)
 S3method(store_read_path,tar_fst)
 S3method(store_read_path,tar_fst_dt)

NEWS.md

@@ -1,7 +1,8 @@
-# targets 1.10.1.9003 (development)
+# targets 1.10.1.9004 (development)
 
 * Upload workspaces to the cloud if `tar_option_get("repository_meta")` is `"aws"` or `"gcp"`. Download them with `tar_workspace_download()` and delete them with `tar_destroy(destroy = "all")` or `tar_destroy(destroy = "cloud")`.
 * Deep-copy settings when resolving `format = "auto"` (#1425, @paulseamer).
+* Add `store_read_path.tar_auto()` (#1429, @paulseamer).
 
 # targets 1.10.1
 

R/class_auto.R

@@ -11,7 +11,7 @@ store_assert_format_setting.auto <- function(format) {
 
 #' @export
 store_get_packages.tar_auto <- function(store) {
-  "qs"
+  "qs2"
 }
 
 #' @export
@@ -53,3 +53,13 @@ store_reformat_auto <- function(target) {
   )
   target_reformat(target, format)
 }
+
+#' @export
+store_read_path.tar_auto <- function(store, path) {
+  path_qs <- path_objects(.subset2(tar_runtime, "store"), basename(path))
+  if_any(
+    identical(path, path_qs),
+    store_read_path.tar_qs(store = store, path = path),
+    store_read_path.tar_store_file(store = store, path = path)
+  )
+}

R/tar_target.R

@@ -50,6 +50,8 @@
 #'
 #'     NOTE: `format = "auto"` slows down pipelines with 10000+ targets
 #'     because it creates deep copies of 20000+ internal data objects.
+#'     Pipelines of this size should use a more explicit format instead of
+#'     `"auto"`.
 #'   * `"qs"`: Uses `qs2::qs_save()` and `qs2::qs_read()`. Should work for
 #'     most objects, much faster than `"rds"`. Optionally configure settings
 #'     through `tar_resources()` and `tar_resources_qs()`.

tests/testthat/test-class_auto.R

@@ -41,7 +41,7 @@ tar_test("auto format with error null", {
 })
 
 tar_test("store_get_packages.tar_auto()", {
-  expect_equal(store_get_packages.tar_auto(list()), "qs")
+  expect_equal(store_get_packages.tar_auto(list()), "qs2")
 })
 
 tar_test("store_reformat_auto()", {
@@ -72,3 +72,24 @@ tar_test("store_path_from_name() file", {
   )
   expect_equal(out, path_objects(path_store_default(), "x"))
 })
+
+tar_test("store_read_path.tar_auto()", {
+  skip_cran()
+  write.csv(data.frame(x = 1), "a.csv")
+  write.csv(data.frame(x = 2), "b.csv")
+  tar_script({
+    list(
+      tar_target(input, c("a.csv", "b.csv"), format = "rds"),
+      tar_target(paths, input, pattern = map(input), format = "file"),
+      tar_target(
+        data,
+        read.csv(paths),
+        pattern = map(paths),
+        format = "auto"
+      ),
+      tar_target(new_data, data, format = "auto")
+    )
+  })
+  tar_make(callr_function = NULL)
+  expect_true(is.data.frame(tar_read(new_data)))
+})