version 0.7.4

DESCRIPTION

@@ -1,15 +1,15 @@
 Package: tarchetypes
 Title: Archetypes for Targets
-Description: Function-oriented Make-like declarative workflows for
+Description: Function-oriented Make-like declarative pipelines for
   Statistics and data science are supported in the 'targets' R package.
   As an extension to 'targets', the 'tarchetypes' package provides
   convenient user-side functions to make 'targets' easier to use.
   By establishing reusable archetypes for common kinds of
   targets and pipelines, these functions help express complicated
-  reproducible workflows concisely and compactly.
+  reproducible pipelines concisely and compactly.
   The methods in this package were influenced by the 'drake' R package
   by Will Landau (2018) <doi:10.21105/joss.00550>.
-Version: 0.7.3
+Version: 0.7.4
 License: MIT + file LICENSE
 URL: https://docs.ropensci.org/tarchetypes/,
         https://github.com/ropensci/tarchetypes
@@ -40,22 +40,22 @@ Authors@R: c(
   ))
 Depends: R (>= 3.5.0)
 Imports: digest (>= 0.6.25), dplyr (>= 1.0.0), fs (>= 1.4.2), furrr (>=
-        0.3.0), rlang (>= 0.4.7), targets (>= 0.11.0), tibble (>=
-        3.0.1), tidyselect (>= 1.1.0), utils, vctrs (>= 0.3.4), withr
-        (>= 2.1.2)
+        0.3.0), future (>= 1.0.0), future.callr (>= 0.2.0), rlang (>=
+        0.4.7), targets (>= 0.14.0), tibble (>= 3.0.1), tidyselect (>=
+        1.1.0), utils, vctrs (>= 0.3.4), withr (>= 2.1.2)
 Suggests: curl (>= 4.3), knitr (>= 1.28), quarto (>= 1.0), rmarkdown
         (>= 2.1), testthat (>= 3.0.0), xml2 (>= 1.3.2)
 Encoding: UTF-8
 Language: en-US
 Config/testthat/edition: 3
-RoxygenNote: 7.2.2
+RoxygenNote: 7.2.3
 NeedsCompilation: no
-Packaged: 2022-11-29 14:40:32 UTC; c240390
+Packaged: 2023-01-05 02:12:03 UTC; c240390
 Author: William Michael Landau [aut, cre]
     (<https://orcid.org/0000-0003-1878-3253>),
   Samantha Oliver [rev] (<https://orcid.org/0000-0001-5668-1165>),
   Tristan Mahr [rev] (<https://orcid.org/0000-0002-8890-5116>),
   Eli Lilly and Company [cph]
 Maintainer: William Michael Landau <will.landau@gmail.com>
 Repository: CRAN
-Date/Publication: 2022-11-29 16:10:02 UTC
+Date/Publication: 2023-01-06 18:50:20 UTC

MD5

@@ -1,7 +1,7 @@
-d1f56b1fc4117ed4467136eccb8d6a1b *DESCRIPTION
+738acb13c749df991cd5860022a5f5dd *DESCRIPTION
 fe2d2df764c64759ba16b27d74c536bc *LICENSE
-48fe1663befa005d59a463c2e8f9e372 *NAMESPACE
-3f6d4f1f3f934fc6fb8c1076f78d4715 *NEWS.md
+7572e6f278cb1d987c56890fccf2754a *NAMESPACE
+a6944b53d39e1341fcfb0f6cd2a54230 *NEWS.md
 72b93a8d242b04ca253f8ed9f4823c5a *R/class_counter.R
 7f2b01f457157283ffe4642ffa86a8fb *R/tar_age.R
 bcc4a635c8f06a33fda37bb43a066de0 *R/tar_change.R
@@ -19,7 +19,7 @@ c8216bf1c1070434c4f98a0d9b848af5 *R/tar_file_read.R
 c578a04d67ee98aa1bec51ab3677f63c *R/tar_files_input.R
 a1b5d3c8eead3e0e7f5b48875e37f35e *R/tar_files_input_raw.R
 4bc902d01345f73e99e12b3ad38766bb *R/tar_files_raw.R
-2cccb195e3a74e097171993bdfd741a4 *R/tar_force.R
+e8a0e0ce332c9015ce2d5b18c84ffa7a *R/tar_force.R
 d07ed32e046e2b8a10972be4feca1089 *R/tar_formats.R
 302d9d99f0b5bdcc4401ed01a8e547a5 *R/tar_group_by.R
 715843486cb768e1b383a9a5c2011d79 *R/tar_group_count.R
@@ -33,31 +33,31 @@ f524655b72151c4458c2ca7fe1be12fc *R/tar_knit.R
 320fe5ea181b9dfb11a9f5418b2a9784 *R/tar_knitr_deps.R
 d9a81733abb72e9809f0a50afcb51661 *R/tar_knitr_deps_expr.R
 520b27bdaa02bdddf568016858388cbd *R/tar_map.R
-23ea457c433ead31cc04e13e69e72588 *R/tar_map2.R
-25b672cc2d47e5df6813b7a7d5fad70a *R/tar_map2_count.R
-108450019b6cb941414a582f8a325f54 *R/tar_map2_count_raw.R
-a1941ec4883bb8f0a16f10fb6a7f266b *R/tar_map2_raw.R
-c77686372ebaa0a34f00dffd5982843d *R/tar_map2_size.R
-f6c7163d29c16710d809cd2dabf22941 *R/tar_map2_size_raw.R
-b1d95737057f9f42a2637ece3ef3190c *R/tar_map_rep.R
-e9e4bfcb8cc86d3c79f705aa15e6c785 *R/tar_map_rep_raw.R
-2c808c2af477c3bb5323516f7da5a475 *R/tar_package.R
+662052eea472d83ac1d032529a9040b5 *R/tar_map2.R
+68ffdfc171929196daf8ee0be7360cff *R/tar_map2_count.R
+195abcfd10a6321b6384f1987d0c0d91 *R/tar_map2_count_raw.R
+e1e363b252140e8765c387a265fb85ca *R/tar_map2_raw.R
+8b271120d2ec57fb4c0cdeb2900a56d3 *R/tar_map2_size.R
+8428ab808c782e458a1914f20e5409ac *R/tar_map2_size_raw.R
+3071e38daf1413d2acad475ddddb8e58 *R/tar_map_rep.R
+b881e41be3f9055491a56bb7ef890803 *R/tar_map_rep_raw.R
+b3c5ae8d2f5f83f9a843d0cc68267aa6 *R/tar_package.R
 2e06d3167abfbd93697dc36ab21e6d43 *R/tar_plan.R
 1f95af88130ecc916d1de6c047fe8e5c *R/tar_quarto.R
 6106dc684627d0b1929348064eea4362 *R/tar_quarto_files.R
 837bc68082f051adfbcbf130e7638bf7 *R/tar_quarto_raw.R
-9885de158edaaf71833daf1074615c34 *R/tar_quarto_rep.R
-a1865541285efe9be7fe798b88fe3a30 *R/tar_quarto_rep_raw.R
+5ac5ce6dbe3a835c44cb3a8efcdc5d1a *R/tar_quarto_rep.R
+fb855baf10dc81810309f028b87c90ae *R/tar_quarto_rep_raw.R
 490514d98b3e8dc9912f473b1cdc788b *R/tar_render.R
 f6949eaea937a1d938e75527004673b5 *R/tar_render_raw.R
-39996934bcd6b8308016cd172996c9c8 *R/tar_render_rep.R
-fda553abb3cb263bb6dde9d7fb9fd440 *R/tar_render_rep_raw.R
-a9b83157ba1634d940e6b08bb1ff3c64 *R/tar_rep.R
-f5c7c4e0c968dcc9cb86fb0aa26a2fc1 *R/tar_rep2.R
-7a2660bfa836d949c564a91574002ffa *R/tar_rep2_raw.R
+90d1fb2171a52ef84757da979c8d47f0 *R/tar_render_rep.R
+55d6d28e8e2ad5359f6caec6e2d12615 *R/tar_render_rep_raw.R
+2d26cf1a65ba2c2dff6af1b53cd0b029 *R/tar_rep.R
+4097cba9be47341baac75d1ef11596ae *R/tar_rep2.R
+640ac3d2987ed6c569a64d3f43d5b532 *R/tar_rep2_raw.R
 0fffd15d8982e5011d29ce1cc3e945dc *R/tar_rep_map.R
 355abc1442790d2d9b0006ef890cfefc *R/tar_rep_map_raw.R
-4218fa67d8e72ad7dabdc68735dbaa2a *R/tar_rep_raw.R
+72713d63d2c21f251f1bdb8c97ed1ad1 *R/tar_rep_raw.R
 9023c14245be4561bf3c6f55ec1c0c02 *R/tar_select_names.R
 a29dbc6f916edbc3e7bb88a14c29254f *R/tar_select_targets.R
 5ea8c924bc7e06d0c262b31e800f8583 *R/tar_skip.R
@@ -68,7 +68,7 @@ d4b1898e5cbf71fe4e2b388d503148c7 *R/tar_tidyselect.R
 f68a0593d854f4129b2071d8764240de *R/utils_ast.R
 f0ed7f5e16018aff63b672fa98dfd72a *R/utils_batch.R
 ce490ffe5b8590dba4385b5cc371985d *R/utils_data.R
-eb966e0dc73a5955e56e4ccd677af1a7 *R/utils_functional.R
+2bb472fe1e5b24e5ccb346ce5d9cc545 *R/utils_functional.R
 6fbb58d427adb10761fd01ba090feae9 *R/utils_knitr.R
 5fdf082c4c21e01f342ab7d344d07fe9 *R/utils_language.R
 c7ab208ad1768d6e5232cd7351e68c54 *R/utils_logic.R
@@ -122,40 +122,45 @@ cc8d63cd54f9da5a20db1d427436a163 *man/tar_knit.Rd
 1c61e98197ff1aac242645ebf92a923c *man/tar_knitr_deps.Rd
 f962cda7f51a5290fed7f82b40a20fa4 *man/tar_knitr_deps_expr.Rd
 6e68d28771e1199ba5db02d66ca71b1f *man/tar_map.Rd
-b0a4e8840926bf2978d8e1fd99cb9732 *man/tar_map2.Rd
-5963b91ad85f8955b13a51260ee954ad *man/tar_map2_count.Rd
-c8c19fe21398c27772d5f3d4a6bcff07 *man/tar_map2_count_raw.Rd
+ee9b258da0b7d3441b09eb480a4f9c69 *man/tar_map2.Rd
+e0113f7fbe26985ebfb12a8c6fb69048 *man/tar_map2_count.Rd
+4a7b70b01bd678600ee4340d93123d92 *man/tar_map2_count_raw.Rd
 b4d773a00ccb1ba8c055b186aec5a0d2 *man/tar_map2_group.Rd
-dadef3645b710d3e471d2fcefa619b6a *man/tar_map2_raw.Rd
-d2755519f0e72084199053347f3e6c01 *man/tar_map2_run.Rd
-f65bcc2224c386b709b5f75e35a5e770 *man/tar_map2_size.Rd
-84ebc9f937ac3fa1690dd04773959d77 *man/tar_map2_size_raw.Rd
-4793e064c66ceffc091fb1756ab519ec *man/tar_map_rep.Rd
-d057d2a411ed261451fe33bfd2f5b41b *man/tar_map_rep_raw.Rd
+3ef4463095ad57d98e9399e2c00252db *man/tar_map2_raw.Rd
+082b7255733e748c7b3ba20260cfa1d2 *man/tar_map2_run.Rd
+30fefb2922d422724c8915082fd8d25d *man/tar_map2_run_rep.Rd
+5a0d6a26c574febc10c26ac6f3f77634 *man/tar_map2_size.Rd
+3e2bc674b88613efddd672a1c5ccd962 *man/tar_map2_size_raw.Rd
+2553615537c83cb87c6054e6145d5e71 *man/tar_map_rep.Rd
+98397db1241ff56f027ebcaa66af127b *man/tar_map_rep_raw.Rd
 0b7cbf327d3dc965f3d349d936480f8b *man/tar_plan.Rd
 791d57891a0e0b6c4739c568040003ac *man/tar_quarto.Rd
 8427f513752a5755ab047dec1f085669 *man/tar_quarto_files.Rd
 1ec5a4205a94f6ecb17070e44176a3bb *man/tar_quarto_raw.Rd
-7bfa3330f7ed83abb51465e46c46e937 *man/tar_quarto_rep.Rd
-bf9525a4281ea856c3743a12b4bee463 *man/tar_quarto_rep_raw.Rd
-fe4d9f73995ae38560231b7a1cd0d7c3 *man/tar_quarto_rep_run.Rd
+b76f3a4c1ac768a0b3779a2515f40ace *man/tar_quarto_rep.Rd
+44475cef462ca8d58a18dd21483b4042 *man/tar_quarto_rep_raw.Rd
+1127bc090f5e53d01a56b38e8aa7ce0e *man/tar_quarto_rep_rep.Rd
+62233c1816a381558a2d628695422f33 *man/tar_quarto_rep_run.Rd
 c3b0e751b4ea1034e04901d2f3e387f4 *man/tar_quarto_rep_run_params.Rd
 2a0968ddf5b155842d7788acad12be81 *man/tar_quarto_run.Rd
 914e146bdd6285a02f5f23557145d0d3 *man/tar_render.Rd
 8734b37ff08566f6e66f274c62a87dac *man/tar_render_raw.Rd
-d71be739a04f33c690a20ca230097c1a *man/tar_render_rep.Rd
-2ff14241c27d6e95399f9b2cb27caad2 *man/tar_render_rep_raw.Rd
-51aa92c94732b5df7c777ca38f1e7a5d *man/tar_render_rep_run.Rd
+d22bec6887fbc8a13fd37aaa3c907d4a *man/tar_render_rep.Rd
+8850af00b33d39b1b53b0b0708da8280 *man/tar_render_rep_raw.Rd
+73e78f2e22116bda2fc8896d04c25ea8 *man/tar_render_rep_rep.Rd
+888cf9efd44aa0d2db819cec5dcab602 *man/tar_render_rep_run.Rd
 1b444c848b705a30225877eef7e582ee *man/tar_render_rep_run_params.Rd
 14882c73ed31768865d7cdade4e7d022 *man/tar_render_run.Rd
-d71bd97dac803ad33c08531b6092ef4a *man/tar_rep.Rd
-91d82352cd46d06f4b2df13ccbf85dcf *man/tar_rep2.Rd
-d75061769e5a116aeebc253ae8511bf8 *man/tar_rep2_raw.Rd
-925c029c956eb2d609f99c119b1e686c *man/tar_rep2_run.Rd
+a827338897dd586a7cd2e38f4f7e1fcf *man/tar_rep.Rd
+c8178b6ee880bcbd7292afd30154550f *man/tar_rep2.Rd
+463aaa044ba8115376fd9ff96e5acde7 *man/tar_rep2_raw.Rd
+68fc80dbb541182474c28506a14401ba *man/tar_rep2_run.Rd
+77cfecf0d2886c6449b8aa0546d81ffe *man/tar_rep2_run_rep.Rd
 a431dadd10255c07de7fc3432e742944 *man/tar_rep_map.Rd
 14928c4f3c968e58a831571c3cc6aa32 *man/tar_rep_map_raw.Rd
-8b78e5c14649596b951cad552945ac77 *man/tar_rep_raw.Rd
-ebe9c58dec32d5be2c269c2f13ac8e7d *man/tar_rep_run.Rd
+e5ef48cc70044713d7dda07e3e0b13ab *man/tar_rep_raw.Rd
+1955e6eccba4fe53a6c8782c721b84aa *man/tar_rep_run.Rd
+229e9c3424e2f1aa2ac22216f48be389 *man/tar_rep_run_map_rep.Rd
 7483a0a78438d0f467d3271068a98bea *man/tar_select_names.Rd
 4af090511627bb6d409f1a063fe925aa *man/tar_select_targets.Rd
 399df0d73037f9dda24b2896efcbd88a *man/tar_skip.Rd
@@ -192,26 +197,26 @@ e2c6954547e3947a39c94b5b5dd63842 *tests/testthat/test-tar_hook_outer.R
 bf591ba56d8333f411247788ea30d8ef *tests/testthat/test-tar_knitr_deps.R
 9181aa76358e8e7b5688508cfe46f9b8 *tests/testthat/test-tar_knitr_deps_expr.R
 20123c4046d9d4519761e3c0ba6e79e2 *tests/testthat/test-tar_map.R
-843eabe5a5e0dcf459aaa6a04051553b *tests/testthat/test-tar_map2.R
-ae814a4d1e9a79a7fc0dd54dc2a7632f *tests/testthat/test-tar_map2_count.R
-5b1b92ff979adba174fde62d2467eba0 *tests/testthat/test-tar_map2_size.R
+86acd537790a95f1b29ce66e194be59a *tests/testthat/test-tar_map2.R
+2a9f01948ca10cd3a1f5f159674c1532 *tests/testthat/test-tar_map2_count.R
+d25ff98919a913a107fdc750cfab4bae *tests/testthat/test-tar_map2_size.R
 381c1bb7a0788522cf9440d3226741a5 *tests/testthat/test-tar_map_rep.R
 ddae77d79fe6fb23ea7b57fc17c13fd0 *tests/testthat/test-tar_plan.R
 6b303c76d8727a2f057bac473b5a1213 *tests/testthat/test-tar_quarto.R
 23d9735f81ad46aed416419879034c70 *tests/testthat/test-tar_quarto_files.R
-fe4d2be28b89462d73fb1669b5641021 *tests/testthat/test-tar_quarto_rep.R
+b387e0534ef66431b44c8b436f6f9d4a *tests/testthat/test-tar_quarto_rep.R
 98a81976cf8647a9bfcf5b78eb4b6a8e *tests/testthat/test-tar_render.R
 038add1b7f010f7c42c7df51db1c818a *tests/testthat/test-tar_render_raw.R
-2b8562c34da01f67e2cf344110a2cac1 *tests/testthat/test-tar_render_rep.R
-652a756aa0bfec04ee88c2f8460c2277 *tests/testthat/test-tar_rep.R
-2a8925473f402cf09e9f32b8b65c8c03 *tests/testthat/test-tar_rep2.R
+c39617ddd731363a12301bf270a234ca *tests/testthat/test-tar_render_rep.R
+2dd46fe20a708e7e89d42cc7f5dbe04e *tests/testthat/test-tar_rep.R
+6ebeecd2396848d0cf101b8afc758122 *tests/testthat/test-tar_rep2.R
 210785f5733a73c22cb91219a5fb4440 *tests/testthat/test-tar_rep_map.R
 c1cacfc3971d8f7add4920c6170eee96 *tests/testthat/test-tar_select_names.R
 777a814894c243c32921d972599da3ac *tests/testthat/test-tar_select_targets.R
-0d204c2660c2714e13d44823f59d5dad *tests/testthat/test-tar_skip.R
+21ff4b130b11efe52acfc8a5a9885a81 *tests/testthat/test-tar_skip.R
 3ed6dcd0088bc67fb22ca55f21b74de6 *tests/testthat/test-tar_sub.R
 e6acd60b5da3f1d892dad462c3c9549d *tests/testthat/test-utils_assert.R
 6ec724bad498bfa94b33717a7e6c9ee5 *tests/testthat/test-utils_ast.R
-ec596d55de3c208edfda289e6cbc2fff *tests/testthat/test-utils_functional.R
+b5c1cb085dd8fc6a72a2a00154c56e26 *tests/testthat/test-utils_functional.R
 b86d37241a82ad46b346a22b437bc27f *tests/testthat/test-utils_knitr.R
 c107941c93dd6d96e98b67ba55ceeaff *tests/testthat/test-utils_logic.R

NAMESPACE

@@ -78,6 +78,7 @@ export(tar_map2_count)
 export(tar_map2_count_raw)
 export(tar_map2_group)
 export(tar_map2_run)
+export(tar_map2_run_rep)
 export(tar_map2_size)
 export(tar_map2_size_raw)
 export(tar_map_rep)
@@ -90,6 +91,7 @@ export(tar_quarto_files)
 export(tar_quarto_raw)
 export(tar_quarto_rep)
 export(tar_quarto_rep_raw)
+export(tar_quarto_rep_rep)
 export(tar_quarto_rep_run)
 export(tar_quarto_rep_run_params)
 export(tar_quarto_run)
@@ -98,17 +100,20 @@ export(tar_render)
 export(tar_render_raw)
 export(tar_render_rep)
 export(tar_render_rep_raw)
+export(tar_render_rep_rep)
 export(tar_render_rep_run)
 export(tar_render_rep_run_params)
 export(tar_render_run)
 export(tar_rep)
 export(tar_rep2)
 export(tar_rep2_raw)
 export(tar_rep2_run)
+export(tar_rep2_run_rep)
 export(tar_rep_map)
 export(tar_rep_map_raw)
 export(tar_rep_raw)
 export(tar_rep_run)
+export(tar_rep_run_map_rep)
 export(tar_select_names)
 export(tar_select_targets)
 export(tar_skip)
@@ -131,6 +136,9 @@ importFrom(fs,path_ext_set)
 importFrom(fs,path_rel)
 importFrom(furrr,furrr_options)
 importFrom(furrr,future_map)
+importFrom(furrr,future_map2)
+importFrom(future,plan)
+importFrom(future.callr,callr)
 importFrom(rlang,as_function)
 importFrom(rlang,call2)
 importFrom(rlang,check_installed)
@@ -188,6 +196,7 @@ importFrom(targets,tar_load)
 importFrom(targets,tar_meta)
 importFrom(targets,tar_option_get)
 importFrom(targets,tar_option_set)
+importFrom(targets,tar_path_target)
 importFrom(targets,tar_read)
 importFrom(targets,tar_runtime_object)
 importFrom(targets,tar_script)

NEWS.md

@@ -1,3 +1,9 @@
+# tarchetypes 0.7.4
+
+* Implement `rep_workers` to control inner parallelism in batched replication functions (#117).
+* Ensure the function passed to `furrr` functions has environment `tar_option_get("envir")`.
+* Allow subdirectories of rendered reports with `tar_quarto_rep()` (#129, @mglev1n).
+
 # tarchetypes 0.7.3
 
 * Support nested futures for parallelism among reps within batches (#117, @kkmann).

R/tar_force.R

@@ -99,7 +99,8 @@ tar_force <- function(
 #'   in [tar_force()].
 tar_force_change <- function(condition) {
   name <- targets::tar_definition()$settings$name
-  path <- file.path(tar_runtime_object()$get_store(), "objects", name)
+  store <- targets::tar_runtime_object()$get_store()
+  path <- targets::tar_path_target(name = name, store = store)
   new <- basename(tempfile(pattern = ""))
   old <- if_any(file.exists(path), readRDS(path), new)
   if_any(condition, new, old)

R/tar_map2.R

@@ -19,11 +19,11 @@
 #'   `command2`, and `command2` dynamically maps over
 #'   these arguments in batches.
 #' @inheritSection tar_rep Replicate-specific seeds
-#' @inheritSection tar_rep Nested futures for batched replication
 #' @return A list of new target objects.
 #'   See the "Target objects" section for background.
 #' @inheritSection tar_map Target objects
 #' @inheritParams tar_map2_raw
+#' @inheritParams tar_rep
 #' @param name Symbol, base name of the targets.
 #' @param command1 R code to create named arguments to `command2`.
 #'   Must return a data frame with one row per call to `command2`.
@@ -48,6 +48,7 @@ tar_map2 <- function(
   suffix2 = "2",
   columns1 = tidyselect::everything(),
   columns2 = tidyselect::everything(),
+  rep_workers = 1,
   tidy_eval = targets::tar_option_get("tidy_eval"),
   packages = targets::tar_option_get("packages"),
   library = targets::tar_option_get("library"),
@@ -75,6 +76,7 @@ tar_map2 <- function(
     suffix2 = suffix2,
     columns1 = substitute(columns1),
     columns2 = substitute(columns2),
+    rep_workers = rep_workers,
     tidy_eval = tidy_eval,
     packages = packages,
     library = library,

R/tar_map2_count.R

@@ -16,7 +16,7 @@
 #'   See the "Target objects" section for background.
 #' @inheritSection tar_map Target objects
 #' @inheritSection tar_rep Replicate-specific seeds
-#' @inheritSection tar_rep Nested futures for batched replication
+#' @inheritParams tar_rep
 #' @inheritParams tar_map2
 #' @inheritParams tar_map2_count_raw
 #' @examples
@@ -54,6 +54,7 @@ tar_map2_count <- function(
   suffix2 = "2",
   columns1 = tidyselect::everything(),
   columns2 = tidyselect::everything(),
+  rep_workers = 1,
   tidy_eval = targets::tar_option_get("tidy_eval"),
   packages = targets::tar_option_get("packages"),
   library = targets::tar_option_get("library"),
@@ -81,6 +82,7 @@ tar_map2_count <- function(
     suffix2 = suffix2,
     columns1 = substitute(columns1),
     columns2 = substitute(columns2),
+    rep_workers = rep_workers,
     tidy_eval = tidy_eval,
     packages = packages,
     library = library,

R/tar_map2_count_raw.R

@@ -19,7 +19,7 @@
 #'   See the "Target objects" section for background.
 #' @inheritSection tar_map Target objects
 #' @inheritSection tar_rep Replicate-specific seeds
-#' @inheritSection tar_rep Nested futures for batched replication
+#' @inheritParams tar_rep
 #' @param batches Positive integer of length 1,
 #'   maximum number of batches (dynamic branches within static branches)
 #'   of the downstream (`command2`) targets. Batches
@@ -62,6 +62,7 @@ tar_map2_count_raw <- function(
   combine = TRUE,
   suffix1 = "1",
   suffix2 = "2",
+  rep_workers = 1,
   columns1 = quote(tidyselect::everything()),
   columns2 = quote(tidyselect::everything()),
   tidy_eval = targets::tar_option_get("tidy_eval"),
@@ -98,6 +99,7 @@ tar_map2_count_raw <- function(
     suffix2 = suffix2,
     columns1 = columns1,
     columns2 = columns2,
+    rep_workers = rep_workers,
     tidy_eval = tidy_eval,
     packages = packages,
     library = library,