Add get_vfpa_hadcp after 06 weather collection

Collect the previous day's observations from the VFPA HADCP located at the 2nd Narrows railway bridge early in the morning after the 06Z weather forecast products have been downloaded. This restores daily collection of the HADCP obs that were inadvertently stopped when we stopped running the VHFR FVCOM model in Mar-2023.
SalishSeaCast · Jul 13, 2024 · 988b23e · 988b23e
1 parent 95a9863
commit 988b23e
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/nowcast/next_workers.py b/nowcast/next_workers.py
@@ -78,6 +78,11 @@ def after_download_weather(msg, config, checklist):
                 next_workers["success 2.5km 06"].append(
                     NextWorker("nowcast.workers.get_onc_ferry", args=[ferry])
                 )
+            next_workers["success 2.5km 06"].append(
+                NextWorker(
+                    "nowcast.workers.get_vfpa_hadcp", args=["--data-date", data_date]
+                )
+            )
             if "forecast2" in config["run types"]:
                 next_workers["success 2.5km 06"].append(
                     NextWorker("nowcast.workers.collect_NeahBay_ssh", args=["00"]),

diff --git a/tests/test_next_workers.py b/tests/test_next_workers.py
@@ -208,6 +208,11 @@ def mock_now():
             NextWorker("nowcast.workers.get_onc_ctd", ["SCVIP"], host="localhost"),
             NextWorker("nowcast.workers.get_onc_ctd", ["SEVIP"], host="localhost"),
             NextWorker("nowcast.workers.get_onc_ctd", ["USDDL"], host="localhost"),
+            NextWorker(
+                "nowcast.workers.get_vfpa_hadcp",
+                ["--data-date", "2018-12-26"],
+                host="localhost",
+            ),
             NextWorker("nowcast.workers.collect_NeahBay_ssh", ["00"], host="localhost"),
         ]
         assert workers == expected
@@ -327,6 +332,11 @@ def mock_now():
             NextWorker("nowcast.workers.get_onc_ctd", ["SCVIP"], host="localhost"),
             NextWorker("nowcast.workers.get_onc_ctd", ["SEVIP"], host="localhost"),
             NextWorker("nowcast.workers.get_onc_ctd", ["USDDL"], host="localhost"),
+            NextWorker(
+                "nowcast.workers.get_vfpa_hadcp",
+                ["--data-date", "2018-12-26"],
+                host="localhost",
+            ),
             NextWorker("nowcast.workers.collect_NeahBay_ssh", ["00"], host="localhost"),
             NextWorker(
                 "nowcast.workers.collect_weather", ["12", "2.5km"], host="localhost"