tar_test("branch$pedigree", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "y", 1L ) expect_true(inherits(branch, "tar_branch")) }) tar_test("branch$pedigree", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "x_1", 1L ) expect_silent(pedigree_validate(branch$pedigree)) expect_equal(settings$name, "x") expect_equal(branch$settings$name, "x_1") }) tar_test("branch priority", { command <- command_init(quote(1 + 1)) settings <- settings_init( name = "x", pattern = quote(map(y)), priority = 0.5 ) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "y", 1L ) expect_equal(branch$settings$priority, 0.5) }) tar_test("branches are not branchable", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "y", 1L ) expect_false(target_is_branchable(branch)) }) tar_test("target_get_name()", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "y", 1L ) expect_equal(settings$name, "x") expect_equal(target_get_name(branch), "y") }) tar_test("target_get_parent(branch)", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "y", 1L ) expect_equal(target_get_parent(branch), "x") }) tar_test("target_deps_deep()", { pipeline <- pipeline_init( list( target_init( name = "data0", expr = quote(seq_len(3L)) ), target_init( name = "data", expr = quote(seq_len(3L)) ), target_init( name = "map", expr = quote(c(data0, data)), pattern = quote(map(data)) ) ) ) local <- local_init(pipeline) local$run() name <- target_get_children(pipeline_get_target(pipeline, "map"))[2] branch <- pipeline_get_target(pipeline, name) bud <- target_get_children(pipeline_get_target(pipeline, "data"))[2] expect_equal( sort(target_deps_deep(branch, pipeline)), sort(c("data0", "data", bud)) ) }) tar_test("branch$produce_record() of a successful branch", { stem <- target_init("x", quote(sample.int(4))) map <- target_init("y", quote(x), pattern = quote(map(x))) pipeline <- pipeline_init(list(stem, map), clone_targets = FALSE) local <- local_init(pipeline) local$run() meta <- local$meta target <- pipeline_get_target(pipeline, target_get_children(map)[2L]) record <- target_produce_record(target, pipeline, meta) expect_silent(record_validate(record)) expect_true(grepl("^y_", record$name)) expect_equal(record$parent, "y") expect_equal(record$type, "branch") expect_equal(nchar(record$command), 16L) expect_equal(nchar(record$depend), 16L) name <- target_get_name(target) expect_equal(record$path, file.path("_targets", "objects", name)) expect_equal(nchar(record$data), 16L) expect_true(record$bytes > 0) expect_true(record$time > 0) expect_equal(record$format, "rds") expect_equal(record$iteration, "vector") expect_equal(record$children, NA_character_) expect_true(is.numeric(record$seconds)) expect_equal(record$warnings, NA_character_) expect_equal(record$error, NA_character_) }) tar_test("branch_validate()", { command <- command_init(quote(1 + 1)) settings <- settings_init(name = "x", pattern = quote(map(y))) cue <- cue_init() branch <- branch_init( command, settings, cue, NULL, character(0), "x_f4acd87c52d4e62b", 1L ) expect_silent(target_validate(branch)) })