From db51aea976309b9fccbb0760bbf9ded53636f31f Mon Sep 17 00:00:00 2001 From: AntonMFernando Date: Tue, 21 Jan 2025 15:18:29 -0500 Subject: [PATCH] modified workflow\rocoto\gfs_tasks.py --- workflow/rocoto/gfs_tasks.py | 23 ++++------------------- 1 file changed, 4 insertions(+), 19 deletions(-) diff --git a/workflow/rocoto/gfs_tasks.py b/workflow/rocoto/gfs_tasks.py index 3ba2591e24..3463c8e9d0 100644 --- a/workflow/rocoto/gfs_tasks.py +++ b/workflow/rocoto/gfs_tasks.py @@ -3012,22 +3012,12 @@ def earc_vrfy(self): deps.append(rocoto.add_dependency(dep_dict)) dependencies = rocoto.create_dependency(dep_condition='and', dep=deps) - earcenvars = self.envars.copy() - earcenvars.append(rocoto.create_envar(name='ENSGRP', value='#grp#')) - - # Integer division is floor division, but we need ceiling division - n_groups = -(self.nmem // -self._configs['earc_vrfy']['NMEM_EARCGRP']) - groups = ' '.join([f'{grp:02d}' for grp in range(0, n_groups + 1)]) - - resources = self.get_resource('earc_tars') - - var_dict = {'grp': groups} + resources = self.get_resource('earc_vrfy') - task_name = f'{self.run}_earc_vrfy_#grp#' + task_name = f'{self.run}_earc_vrfy' task_dict = {'task_name': task_name, 'resources': resources, 'dependency': dependencies, - 'envars': earcenvars, 'cycledef': self.run.replace('enkf', ''), 'command': f'{self.HOMEgfs}/jobs/rocoto/earc_vrfy.sh', 'job_name': f'{self.pslot}_{task_name}_@H', @@ -3035,12 +3025,7 @@ def earc_vrfy(self): 'maxtries': '&MAXTRIES;' } - metatask_dict = {'task_name': f'{self.run}_eamn', - 'var_dict': var_dict, - 'task_dict': task_dict - } - - task = rocoto.create_task(metatask_dict) + task = rocoto.create_task(task_dict) return task @@ -3079,7 +3064,7 @@ def earc_tars(self): 'maxtries': '&MAXTRIES;' } - metatask_dict = {'task_name': f'{self.run}_eamn', + metatask_dict = {'task_name': f'{self.run}_earc_tars', 'var_dict': var_dict, 'task_dict': task_dict }