reporter coverage

R/class_crew.R

@@ -230,6 +230,8 @@ crew_class <- R6::R6Class(
       if (is.null(result)) {
         return()
       }
+      # Tested in tests/testthat/test-crew_retries.R.
+      # nocov start
       if (result$status == "crash") {
         target <- pipeline_get_target(self$pipeline, result$name)
         self$scheduler$reporter$report_retry(
@@ -239,6 +241,7 @@ crew_class <- R6::R6Class(
         self$run_target(target)
         return()
       }
+      # nocov end
       tar_assert_all_na(
         result$error,
         msg = paste("target", result$name, "error:", result$error)

tests/testthat/test-class_reporter.R

@@ -0,0 +1,17 @@
+tar_test("reporter abstract class", {
+  skip_cran()
+  x <- reporter_class$new()
+  expect_null(x$report_start())
+  expect_message(x$report_error("x"), class = "tar_condition_run")
+  expect_null(x$report_completed())
+  expect_null(x$report_skipped())
+  expect_null(x$report_errored())
+  expect_null(x$report_canceled())
+  expect_null(x$report_outdated(NULL))
+  expect_null(x$report_outdated_end(NULL))
+  expect_null(x$report_workspace(NULL))
+  expect_null(x$report_retry())
+  expect_null(x$report_finalize())
+  expect_null(x$flush_messages())
+  expect_null(x$validate())
+})

tests/testthat/test-class_summary.R

@@ -20,6 +20,17 @@ tar_test("run summary reporter with a cancellation", {
   expect_message(local$run())
 })
 
+tar_test("summary reporter retry message", {
+  pipeline <- pipeline_init(
+    list(target_init("x", quote(TRUE)))
+  )
+  local <- local_init(pipeline, reporter = "summary")
+  expect_message(local$run())
+  expect_message(
+    local$scheduler$reporter$report_retry(progress = local$scheduler$progress)
+  )
+})
+
 tar_test("validate summary reporter", {
   expect_silent(reporter_init("summary")$validate())
 })

tests/testthat/test-class_timestamp.R

@@ -33,6 +33,18 @@ tar_test("run timestamp reporter with a cancellation", {
   expect_message(local$run())
 })
 
+tar_test("timestamp reporter retry message", {
+  pipeline <- pipeline_init(list(target_init("x", quote(TRUE))))
+  local <- local_init(pipeline, reporter = "timestamp")
+  local$run()
+  expect_message(
+    local$scheduler$reporter$report_retry(
+      target = local$pipeline$targets$x,
+      progress = local$scheduler$progress
+    )
+  )
+})
+
 tar_test("validate timestamp reporter", {
   expect_silent(reporter_init("timestamp")$validate())
 })

tests/testthat/test-class_verbose.R

@@ -25,6 +25,18 @@ tar_test("run verbose reporter with a warning", {
   )
 })
 
+tar_test("verbose reporter retry message", {
+  pipeline <- pipeline_init(list(target_init("x", quote(TRUE))))
+  local <- local_init(pipeline, reporter = "verbose")
+  local$run()
+  expect_message(
+    local$scheduler$reporter$report_retry(
+      target = local$pipeline$targets$x,
+      progress = local$scheduler$progress
+    )
+  )
+})
+
 tar_test("validate verbose reporter", {
   expect_silent(reporter_init("verbose")$validate())
 })

tests/testthat/test-utils_cli.R

@@ -23,6 +23,12 @@ tar_test("cli_cancel()", {
   expect_message(cli_cancel("x", time_stamp = TRUE))
 })
 
+tar_test("cli_cancel()", {
+  skip_cran()
+  expect_message(cli_retry("x", time_stamp = TRUE))
+  expect_message(cli_retry("x", time_stamp = FALSE))
+})
+
 tar_test("cli_pipeline_uptodate()", {
   skip_cran()
   expect_message(cli_pipeline_uptodate(seconds_elapsed = 1))
@@ -58,6 +64,11 @@ tar_test("cli_blue_play()", {
   expect_message(cli_blue_play("x"))
 })
 
+tar_test("cli_magenta_play()", {
+  skip_cran()
+  expect_message(cli_magenta_play("x"))
+})
+
 tar_test("cli_green_record()", {
   skip_cran()
   expect_message(cli_green_record("x"))