Resume hindcast results downloading re: v202111

SalishSeaCast · Oct 5, 2022 · 7066ba8 · 7066ba8
1 parent 6d9c4a9
commit 7066ba8
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/nowcast/next_workers.py b/nowcast/next_workers.py
@@ -889,6 +889,15 @@ def after_watch_NEMO_hindcast(msg, config, checklist):
     if msg.type == "success":
         next_workers[msg.type].extend(
             [
+                NextWorker(
+                    "nowcast.workers.download_results",
+                    args=[
+                        msg.payload["hindcast"]["host"],
+                        "hindcast",
+                        "--run-date",
+                        msg.payload["hindcast"]["run date"],
+                    ],
+                ),
                 NextWorker(
                     "nowcast.workers.watch_NEMO_hindcast",
                     args=[msg.payload["hindcast"]["host"]],

diff --git a/tests/test_next_workers.py b/tests/test_next_workers.py
@@ -1943,7 +1943,7 @@ def test_no_next_worker_msg_types(self, msg_type, config, checklist):
             )
         ],
     )
-    def test_success_not_launch_download_results(self, msg, config, checklist):
+    def test_success_launch_download_results(self, msg, config, checklist):
         workers = next_workers.after_watch_NEMO_hindcast(msg, config, checklist)
         expected = NextWorker(
             "nowcast.workers.download_results",
@@ -1955,7 +1955,7 @@ def test_success_not_launch_download_results(self, msg, config, checklist):
             ],
             host="localhost",
         )
-        assert expected not in workers
+        assert expected in workers
 
     @pytest.mark.parametrize(
         "msg",