Skip to content

Commit

Permalink
Add new GSI monitor jobs to task creation
Browse files Browse the repository at this point in the history
  • Loading branch information
KateFriedman-NOAA committed Oct 18, 2023
1 parent 7dc2753 commit 0f984dd
Showing 1 changed file with 33 additions and 0 deletions.
33 changes: 33 additions & 0 deletions workflow/rocoto/gfs_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -857,6 +857,39 @@ def gempak(self):

return task

def verfozn(self):
deps = []
dep_dict = {'type': 'task', 'name': f'{self.cdump}analdiag'}
deps.append(rocoto.add_dependency(dep_dict))
dependencies = rocoto.create_dependency(dep=deps)

resources = self.get_resource('verfozn')
task = create_wf_task('verfozn', resources, cdump=self.cdump, envar=self.envars, dependency=dependencies)

return task

def verfrad(self):
deps = []
dep_dict = {'type': 'task', 'name': f'{self.cdump}analdiag'}
deps.append(rocoto.add_dependency(dep_dict))
dependencies = rocoto.create_dependency(dep=deps)

resources = self.get_resource('verfrad')
task = create_wf_task('verfrad', resources, cdump=self.cdump, envar=self.envars, dependency=dependencies)

return task

def vminmon(self):
deps = []
dep_dict = {'type': 'task', 'name': f'{self.cdump}anal'}
deps.append(rocoto.add_dependency(dep_dict))
dependencies = rocoto.create_dependency(dep=deps)

resources = self.get_resource('vminmon')
task = create_wf_task('vminmon', resources, cdump=self.cdump, envar=self.envars, dependency=dependencies)

return task

def vrfy(self):
deps = []
dep_dict = {'type': 'metatask', 'name': f'{self.cdump}post'}
Expand Down

0 comments on commit 0f984dd

Please sign in to comment.