Skip to content

Commit

Permalink
modified gefs_tasks.py
Browse files Browse the repository at this point in the history
  • Loading branch information
AntonMFernando-NOAA committed Oct 19, 2024
1 parent d96631e commit 08c4f12
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions workflow/rocoto/gefs_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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}

Expand Down Expand Up @@ -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#'}
Expand Down

0 comments on commit 08c4f12

Please sign in to comment.