diff --git a/workflow/rocoto/gefs_tasks.py b/workflow/rocoto/gefs_tasks.py index f5cd4edc91..a96e3b4465 100644 --- a/workflow/rocoto/gefs_tasks.py +++ b/workflow/rocoto/gefs_tasks.py @@ -329,7 +329,7 @@ def wavepostsbs(self): wave_post_envars.append(rocoto.create_envar(name=key, value=str(value))) - task_name = f'gefs_wave_post_grid_mem#member#_f#fhr#' + task_name = f'gefs_wave_post_grid_#member#_f#fhr#' task_dict = {'task_name': task_name, 'resources': resources, 'dependency': dependencies, @@ -344,7 +344,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_mem#member#', + fhr_metatask_dict = {'task_name': f'gefs_wave_post_grid_#member#', 'task_dict': task_dict, 'var_dict': fhr_var_dict} @@ -352,6 +352,7 @@ def wavepostsbs(self): member_metatask_dict = {'task_name': f'gefs_wave_post_grid', 'task_dict': fhr_metatask_dict, 'var_dict': member_var_dict} + task = rocoto.create_task(member_metatask_dict) return task