diff --git a/workflow/rocoto/gefs_tasks.py b/workflow/rocoto/gefs_tasks.py index 4c77ed483b..4ca1cc29d7 100644 --- a/workflow/rocoto/gefs_tasks.py +++ b/workflow/rocoto/gefs_tasks.py @@ -327,7 +327,7 @@ def wavepostsbs(self): for key, value in wave_post_dict.items(): wave_post_envars.append(rocoto.create_envar(name=key, value=str(value))) - task_name = f'gefs_wave_post_grid_#member#_f#fhr#' + task_name = f'gefs_wave_post_grid_mem#member#_f#fhr#' task_dict = {'task_name': task_name, 'resources': resources, 'dependency': dependencies, @@ -342,7 +342,7 @@ def wavepostsbs(self): fhrs = self._get_forecast_hours('gefs', self._configs['wavepostsbs']) fhr_var_dict = {'fhr': ' '.join([f"{fhr:03d}" for fhr in fhrs])} - fhr_metatask_dict = {'task_name': f'gefs_wave_post_grid_#member#', + fhr_metatask_dict = {'task_name': f'gefs_wave_post_grid_mem#member#', 'task_dict': task_dict, 'var_dict': fhr_var_dict} @@ -478,7 +478,7 @@ def wavepostpnt(self): def extractvars(self): deps = [] if self.app_config.do_wave: - dep_dict = {'type': 'metatask', 'name': 'gefs_wave_post_grid_#member#'} + dep_dict = {'type': 'metatask', 'name': 'gefs_wave_post_grid_mem#member#'} deps.append(rocoto.add_dependency(dep_dict)) if self.app_config.do_ocean: dep_dict = {'type': 'metatask', 'name': 'gefs_ocean_prod_#member#'}