Add an archive task to GEFS system to archive files in HPSS

parm/archive/gefs.yaml.j2

@@ -0,0 +1,33 @@
+{% set cycle_HH = current_cycle | strftime("%H") %}
+{% set cycle_YMD = current_cycle | to_YMD %}
+{% set cycle_YMDH = current_cycle | to_YMDH %}
+{% set head = RUN + ".t" + cycle_HH + "z." %}
+
+gefs:
+    name: "GEFS"
+    target: "{{ ATARDIR }}/{{ cycle_YMDH }}/gefs.tar"
+    required:
+    {% set file_set = [] %}
+
+    {% set tmpl_dict = ({ '${ROTDIR}':ROTDIR,
+                          '${RUN}':RUN,
+                          '${YMD}':cycle_YMD,
+                          '${HH}':cycle_HH,
+                          '${GRID}': '0p50',
+                          '${MEMDIR}': 'mem000' }) %}
+
+    {% set COMIN_ATMOS_GRIB_1p00 = COM_ATMOS_GRIB_GRID_TMPL | replace_tmpl(tmpl_dict) %}
+
+    # Select ensstat files to copy to the arcdir
+    {% if RUN == "gefs" %}
+        {% set ensstat_files = [] %}
+        {% if path_exists(COMIN_ATMOS_GRIB_1p00) %}
+            {% for fhr in range(FHMIN_GFS, FHMAX_GFS + FHOUT_GFS - 50, FHOUT_GFS) %}
+                {% do ensstat_files.append([COMIN_ATMOS_GRIB_1p00 ~ "/" ~ head ~ "pgrb2a." ~
+                                            "1p00" ~ ".f" ~ '%03d'|format(fhr) ~ ".grib2",
+                                            GEFS_ARCH]) %}
+            {% endfor %}
+        {% endif %}
+    {% endif %}
+    {% set file_set = ensstat_files %}
+    - "{{ file_set }}"

parm/archive/master_gefs.yaml.j2

@@ -0,0 +1,9 @@
+# Set variables/lists needed to parse the gefs templates
+{% set cycle_HH = current_cycle | strftime("%H") %}
+{% set cycle_YMD = current_cycle | to_YMD %}
+{% set cycle_YMDH = current_cycle | to_YMDH %}
+
+datasets:
+{% filter indent(width=4) %}
+{% include "gefs.yaml.j2" %}
+{% endfilter %}

parm/config/gefs/yaml/defaults.yaml

@@ -15,4 +15,4 @@ base:
   REPLAY_ICS: "NO"
   USE_OCN_PERTURB_FILES: "false"
   HPSSARCH: "NO"
-  LOCALARCH: "NO"
+  LOCALARCH: "YES"

ush/python/pygfs/task/archive.py

@@ -114,9 +114,6 @@ def configure(self, arch_dict: Dict[str, Any]) -> (Dict[str, Any], List[Dict[str
             self.tar_cmd = ""
             return arcdir_set, []
 
-        if arch_dict.NET == "gefs":
-            raise NotImplementedError("GEFS archiving is not yet implemented!")
-
         master_yaml = "master_" + arch_dict.RUN + ".yaml.j2"
 
         parsed_sets = parse_j2yaml(os.path.join(archive_parm, master_yaml),