don't submit the climatological until they're ready

Author: dsweber2

scripts/covid_hosp_prod.R

@@ -1,6 +1,7 @@
 # The COVID Hospitalization Production Forecasting Pipeline.
 source("scripts/targets-common.R")
 
+submit_climatological <- FALSE
 submission_directory <- Sys.getenv("COVID_SUBMISSION_DIRECTORY", "cache")
 insufficient_data_geos <- c("as", "mp", "vi", "gu")
 # date to cut the truth data off at, so we don't have too much of the past
@@ -143,18 +144,20 @@ rlang::list2(
     tar_target(
       name = make_climate_submission_csv,
       command = {
-        forecasts <- forecast_res
-        forecasts %>%
-          filter(forecaster %in% c("climate_base", "climate_geo_agged")) %>%
-          group_by(geo_value, target_end_date, quantile) %>%
-          summarize(forecast_date = first(forecast_date), value = mean(value, na.rm = TRUE), .groups = "drop") %>%
-          ungroup() %>%
-          format_flusight(disease = "covid") %>%
-          write_submission_file(
-            get_forecast_reference_date(as.Date(forecast_generation_date)),
-            submission_directory = file.path(submission_directory, "model-output/CMU-climatological-baseline"),
-            file_name = "CMU-climatological-baseline"
-          )
+        if (submit_climatological) {
+          forecasts <- forecast_res
+          forecasts %>%
+            filter(forecaster %in% c("climate_base", "climate_geo_agged")) %>%
+            group_by(geo_value, target_end_date, quantile) %>%
+            summarize(forecast_date = first(forecast_date), value = mean(value, na.rm = TRUE), .groups = "drop") %>%
+            ungroup() %>%
+            format_flusight(disease = "covid") %>%
+            write_submission_file(
+              get_forecast_reference_date(as.Date(forecast_generation_date)),
+              submission_directory = file.path(submission_directory, "model-output/CMU-climatological-baseline"),
+              file_name = "CMU-climatological-baseline"
+            )
+        }
       },
       cue = tar_cue(mode = "always")
     ),
@@ -180,7 +183,7 @@ rlang::list2(
       command = {
         make_climate_submission_csv
         # only validate if we're saving the result to a hub
-        if (submission_directory != "cache") {
+        if (submission_directory != "cache" && submit_climatological) {
           validation <- validate_submission(
             submission_directory,
             file_path = sprintf("CMU-climatological-baseline/%s-CMU-climatological-baseline.csv", get_forecast_reference_date(as.Date(forecast_generation_date)))

scripts/flu_hosp_prod.R

@@ -202,18 +202,20 @@ rlang::list2(
     tar_target(
       name = make_climate_submission_csv,
       command = {
-        forecasts <- forecast_res
-        forecasts %>%
-          filter(forecaster %in% c("climate_base", "climate_geo_agged")) %>%
-          group_by(geo_value, target_end_date, quantile) %>%
-          summarize(forecast_date = first(forecast_date), value = mean(value, na.rm = TRUE), .groups = "drop") %>%
-          ungroup() %>%
-          format_flusight(disease = "flu") %>%
-          write_submission_file(
-            get_forecast_reference_date(as.Date(forecast_generation_date)),
-            submission_directory = file.path(submission_directory, "model-output/CMU-climatological-baseline"),
-            file_name = "CMU-climatological-baseline"
-          )
+        if (submit_climatological) {
+          forecasts <- forecast_res
+          forecasts %>%
+            filter(forecaster %in% c("climate_base", "climate_geo_agged")) %>%
+            group_by(geo_value, target_end_date, quantile) %>%
+            summarize(forecast_date = first(forecast_date), value = mean(value, na.rm = TRUE), .groups = "drop") %>%
+            ungroup() %>%
+            format_flusight(disease = "flu") %>%
+            write_submission_file(
+              get_forecast_reference_date(as.Date(forecast_generation_date)),
+              submission_directory = file.path(submission_directory, "model-output/CMU-climatological-baseline"),
+              file_name = "CMU-climatological-baseline"
+            )
+        }
       },
       cue = tar_cue(mode = "always")
     ),
@@ -239,7 +241,7 @@ rlang::list2(
       command = {
         make_climate_submission_csv
         # only validate if we're saving the result to a hub
-        if (submission_directory != "cache") {
+        if (submission_directory != "cache" && submit_climatological) {
           validation <- validate_submission(
             submission_directory,
             file_path = sprintf("CMU-climatological-baseline/%s-CMU-climatological-baseline.csv", get_forecast_reference_date(as.Date(forecast_generation_date)))