modified gefs_task.py

AntonMFernando-NOAA · Oct 18, 2024 · 16205f1 · 16205f1
1 parent 3c69e48
commit 16205f1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git 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,14 +344,15 @@ 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}
 
         member_var_dict = {'member': ' '.join([f"{mem:03d}" for mem in range(0, self.nmem + 1)])}
         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