Skip to content

Commit

Permalink
Include YYMMDDHH in the job scheduler job name
Browse files Browse the repository at this point in the history
  • Loading branch information
@EricSinsky-NOAA
EricSinsky-NOAA committed Oct 24, 2024
1 parent 312147d commit 0d7a3dc
Showing 1 changed file with 15 additions and 15 deletions.
30 changes: 15 additions & 15 deletions workflow/rocoto/gefs_tasks.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ def stage_ic(self):
'envars': self.envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/stage_ic.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand All @@ -36,7 +36,7 @@ def waveinit(self):
'envars': self.envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/waveinit.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand All @@ -57,7 +57,7 @@ def prep_emissions(self):
'envars': self.envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/prep_emissions.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -95,7 +95,7 @@ def fcst(self):
'envars': fcst_vars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/fcst.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -140,7 +140,7 @@ def repair_replay(self):
'envars': repair_replay_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/repair_replay.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -196,7 +196,7 @@ def efcs(self):
'envars': efcsenvars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/fcst.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -308,7 +308,7 @@ def _atmosoceaniceprod(self, component: str):
'envars': postenvars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/{config}.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'}

Expand Down Expand Up @@ -354,7 +354,7 @@ def atmos_ensstat(self):
'envars': postenvars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/atmos_ensstat.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'}

Expand Down Expand Up @@ -388,7 +388,7 @@ def wavepostsbs(self):
'envars': wave_post_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/wavepostsbs.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -424,7 +424,7 @@ def wavepostbndpnt(self):
'envars': wave_post_bndpnt_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/wavepostbndpnt.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -469,7 +469,7 @@ def wavepostbndpntbll(self):
'envars': wave_post_bndpnt_bull_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/wavepostbndpntbll.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -508,7 +508,7 @@ def wavepostpnt(self):
'envars': wave_post_pnt_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/wavepostpnt.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -553,7 +553,7 @@ def extractvars(self):
'envars': extractvars_envars,
'cycledef': 'gefs',
'command': f'{self.HOMEgfs}/jobs/rocoto/extractvars.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -603,7 +603,7 @@ def arch(self):
'cycledef': 'gefs',
'dependency': dependencies,
'command': f'{self.HOMEgfs}/jobs/rocoto/arch.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down Expand Up @@ -649,7 +649,7 @@ def cleanup(self):
'cycledef': 'gefs',
'dependency': dependencies,
'command': f'{self.HOMEgfs}/jobs/rocoto/cleanup.sh',
'job_name': f'{self.pslot}_{task_name}_@H',
'job_name': f'{self.pslot}_{task_name}_@Y@m@d@H',
'log': f'{self.rotdir}/logs/@Y@m@d@H/{task_name}.log',
'maxtries': '&MAXTRIES;'
}
Expand Down

0 comments on commit 0d7a3dc

Please sign in to comment.