docs

R/class_forecast.R

@@ -15,9 +15,13 @@ forecast_class <- R6::R6Class(
         self$buffer <- NULL
       }
     },
-    report_outdated = function(outdated) {
-      self$buffer <- cli_forecast(outdated$cli_data(), print = FALSE)
-      self$poll()
+    report_outdated = function(outdated, force = FALSE) {
+      now <- time_seconds_local()
+      if (force || ((now - seconds_flushed) > seconds_interval)) {
+        self$buffer <- cli_forecast(outdated$cli_data(), print = FALSE)
+        flush_messages()
+        self$seconds_flushed <- now
+      }
     },
     report_end = function(progress = NULL, seconds_elapsed = NULL) {
       self$flush_messages()

R/class_outdated.R

@@ -172,11 +172,11 @@ outdated_class <- R6::R6Class(
       target <- pipeline_get_target(pipeline, name)
       if_any(
         inherits(target, "tar_pattern"),
-        self$process_pattern(target),
-        self$process_builder(target)
+        process_pattern(target),
+        process_builder(target)
       )
-      self$register_checked(name)
-      self$scheduler$reporter$report_outdated(self)
+      register_checked(name)
+      scheduler$reporter$report_outdated(self)
     },
     run = function() {
       self$start()
@@ -188,6 +188,7 @@ outdated_class <- R6::R6Class(
         name <- dequeue()
         self$process_target(name, pipeline)
       }
+      self$scheduler$reporter$report_outdated(self, force = TRUE)
       self$end()
     },
     validate = function() {

R/class_reporter.R

@@ -67,7 +67,7 @@ reporter_class <- R6::R6Class(
     },
     report_canceled = function(target = NULL, progress = NULL) {
     },
-    report_outdated = function(outdated) {
+    report_outdated = function(outdated, force = FALSE) {
     },
     report_workspace = function(target) {
     },

R/class_silent.R

@@ -7,6 +7,5 @@ silent_class <- R6::R6Class(
   inherit = reporter_class,
   class = FALSE,
   portable = FALSE,
-  cloneable = FALSE,
-  public = list()
+  cloneable = FALSE
 )

R/tar_config_set.R

@@ -84,6 +84,10 @@
 #'   When the pipeline ends,
 #'   all the metadata and progress data is saved immediately,
 #'   regardless of `seconds_meta_append`.
+#'
+#'   When the pipeline is just skipping targets, the actual interval
+#'   between saves is `max(1, seconds_meta_append)` to reduce
+#'   overhead.
 #' @param seconds_meta_upload Argument of [tar_make()], [tar_make_clustermq()],
 #'   and [tar_make_future()].
 #'   Positive numeric of length 1 with the minimum
@@ -100,6 +104,9 @@
 #'   number of seconds between times when the reporter prints progress
 #'   messages to the R console (for the aforementioned
 #'   [tar_make()]-like functions only).
+#'   When the pipeline is just skipping targets,
+#'   the actual interval between messages is `max(1, seconds_reporter)`
+#'   to reduce overhead.
 #' @param seconds_reporter_outdated Argument of [tar_outdated()]
 #'   and other related functions that do not run the pipeline.
 #'   Positive numeric of length 1 with the minimum

R/tar_make.R

@@ -58,6 +58,10 @@
 #'   When the pipeline ends,
 #'   all the metadata and progress data is saved immediately,
 #'   regardless of `seconds_meta_append`.
+#'
+#'   When the pipeline is just skipping targets, the actual interval
+#'   between saves is `max(1, seconds_meta_append)` to reduce
+#'   overhead.
 #' @param seconds_meta_upload Positive numeric of length 1 with the minimum
 #'   number of seconds between uploads of the metadata and progress data
 #'   to the cloud
@@ -69,7 +73,9 @@
 #'   regardless of `seconds_meta_upload`.
 #' @param seconds_reporter Positive numeric of length 1 with the minimum
 #'   number of seconds between times when the reporter prints progress
-#'   messages to the R console.
+#'   messages to the R console. When the pipeline is just skipping targets,
+#'   the actual interval between messages is `max(1, seconds_reporter)`
+#'   to reduce overhead.
 #' @param garbage_collection Deprecated. Use the `garbage_collection`
 #'   argument of [tar_option_set()] instead to run garbage collection
 #'   at regular intervals in a pipeline, or use the argument of the same