Remove anl from post task and replace with new task

jobs/rocoto/post.sh

@@ -16,11 +16,7 @@ status=$?
 export job="post"
 export jobid="${job}.$$"
 
-if [ ${FHRGRP} = 'anl' ]; then
-    fhrlst="anl"
-else
-    fhrlst=$(echo ${FHRLST} | sed -e 's/_/ /g; s/f/ /g; s/,/ /g')
-fi
+fhrlst=$(echo ${FHRLST} | sed -e 's/_/ /g; s/f/ /g; s/,/ /g')
 
 #---------------------------------------------------------------
 for fhr in ${fhrlst}; do

jobs/rocoto/postanl.sh

@@ -0,0 +1,29 @@
+#! /usr/bin/env bash
+
+source "${HOMEgfs}/ush/preamble.sh"
+
+###############################################################
+## NCEP post driver script
+## FHRGRP : forecast hour group to post-process (e.g. 0)
+## FHRLST : forecast hourlist to be post-process (e.g. anl)
+###############################################################
+
+# Source FV3GFS workflow modules
+. ${HOMEgfs}/ush/load_fv3gfs_modules.sh
+status=$?
+[[ ${status} -ne 0 ]] && exit ${status}
+
+export job="postanl"
+export jobid="${job}.$$"
+
+fhrlst=$(echo ${FHRLST} | sed -e 's/_/ /g; s/f/ /g; s/,/ /g')
+
+#---------------------------------------------------------------
+for fhr in ${fhrlst}; do
+    export post_times=${fhr}
+    ${HOMEgfs}/jobs/JGLOBAL_ATMOS_POST
+    status=$?
+    [[ ${status} -ne 0 ]] && exit ${status}
+done
+
+exit 0

workflow/applications/gfs_cycled.py

@@ -101,7 +101,7 @@ def get_task_names(self):
         """
 
         gdas_gfs_common_tasks_before_fcst = ['prep']
-        gdas_gfs_common_tasks_after_fcst = ['post']
+        gdas_gfs_common_tasks_after_fcst = ['postanl', 'post']
         # if self.do_ocean:  # TODO: uncomment when ocnpost is fixed in cycled mode
         #    gdas_gfs_common_tasks_after_fcst += ['ocnpost']
         gdas_gfs_common_tasks_after_fcst += ['vrfy']

workflow/hosts/awspw.yaml

@@ -21,4 +21,4 @@ LOCALARCH: 'NO'
 ATARDIR: '/NCEPDEV/${HPSS_PROJECT}/1year/${USER}/${machine}/scratch/${PSLOT}' # TODO: This will not yet work from AWS.
 MAKE_NSSTBUFR: 'NO'
 MAKE_ACFTBUFR: 'NO'
-SUPPORTED_RESOLUTIONS: ['C48'] # TODO: Test and support all cubed-sphere resolutions.
+SUPPORTED_RESOLUTIONS: ['C48', 'C96'] # TODO: Test and support all cubed-sphere resolutions.

workflow/rocoto/gfs_tasks.py

@@ -554,16 +554,33 @@ def _fcst_cycled(self):
     def post(self):
         add_anl_to_post = False
         if self.app_config.mode in ['cycled']:
-            add_anl_to_post = True
+            add_anl_to_post = False
 
         return self._post_task('post', add_anl_to_post=add_anl_to_post)
 
+    def postanl(self):
+        postenvars = self.envars.copy()
+        for key, value in postenvar_dict.items():
+            postenvars.append(rocoto.create_envar(name=key, value=str(value)))
+
+        deps = []
+        atm_hist_path = self._template_to_rocoto_cycstring(self._base["COM_ATMOS_HISTORY_TMPL"])
+        data = f'{atm_hist_path}/{self.cdump}.t@Hz.atm.loganl.txt'
+        dep_dict = {'type': 'data', 'data': data}
+        deps.append(rocoto.add_dependency(dep_dict))
+        dependencies = rocoto.create_dependency(dep=deps)
+        resources = self.get_resource('post')
+        task = create_wf_task('postanl', resources, cdump=self.cdump, envar=postenvars, dependency=dependencies,
+                              cycledef=self.cdump)
+
+        return task
+
     def ocnpost(self):
         if self.app_config.mode in ['forecast-only']:  # TODO: fix ocnpost in cycled mode
             return self._post_task('ocnpost', add_anl_to_post=False)
 
     def _post_task(self, task_name, add_anl_to_post=False):
-        if task_name not in ['post', 'ocnpost']:
+        if task_name not in ['postanl', 'post', 'ocnpost']:
             raise KeyError(f'Invalid post-processing task: {task_name}')
 
         if task_name in ['ocnpost']:
@@ -620,7 +637,7 @@ def _get_postgroups(cdump, config, add_anl=False):
             postenvars.append(rocoto.create_envar(name=key, value=str(value)))
 
         varname1, varname2, varname3 = 'grp', 'dep', 'lst'
-        varval1, varval2, varval3 = _get_postgroups(self.cdump, self._configs[task_name], add_anl=add_anl_to_post)
+        varval1, varval2, varval3 = _get_postgroups(self.cdump, self._configs[task_name], add_anl=False)
         vardict = {varname2: varval2, varname3: varval3}
 
         cycledef = 'gdas_half,gdas' if self.cdump in ['gdas'] else self.cdump