From 5d2dc1cff0189129e00702f68f7e2132281e5920 Mon Sep 17 00:00:00 2001 From: DavidHuber Date: Fri, 13 Sep 2024 12:02:18 +0000 Subject: [PATCH] Add metp dependency for gfscleanup #2899 --- workflow/rocoto/gfs_tasks.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/workflow/rocoto/gfs_tasks.py b/workflow/rocoto/gfs_tasks.py index 89da933d00..4abf0e5529 100644 --- a/workflow/rocoto/gfs_tasks.py +++ b/workflow/rocoto/gfs_tasks.py @@ -855,8 +855,8 @@ def fcst(self): try: task = fcst_map[self.app_config.mode]() except KeyError: - raise NotImplementedError(f'{self.app_config.mode} is not a valid type.\n' + - 'Currently supported forecast types are:\n' + + raise NotImplementedError(f'{self.app_config.mode} is not a valid type.\n' + f'Currently supported forecast types are:\n' f'{" | ".join(fcst_map.keys())}') return task @@ -2330,6 +2330,11 @@ def cleanup(self): dep_dict = {'type': 'task', 'name': f'{self.run}npoess_pgrb2_0p5deg'} deps.append(rocoto.add_dependency(dep_dict)) + if self.run in ['gfs']: + if self.app_config.do_metp: + dep_dict = {'type': 'metatask', 'name': f'{self.run}metp'} + deps.append(rocoto.add_dependency(dep_dict)) + dependencies = rocoto.create_dependency(dep_condition='and', dep=deps) resources = self.get_resource('cleanup')