diff --git a/sorc/gdas.cd b/sorc/gdas.cd index 74a32ae36d..42f2113366 160000 --- a/sorc/gdas.cd +++ b/sorc/gdas.cd @@ -1 +1 @@ -Subproject commit 74a32ae36dd5032f5e41171ad652c3a6e862275d +Subproject commit 42f2113366625c7e8d891e49c1fc06a125fd8608 diff --git a/ush/python/pygfs/task/ensemble_center.py b/ush/python/pygfs/task/ensemble_center.py index ca51218426..7c001c7dec 100644 --- a/ush/python/pygfs/task/ensemble_center.py +++ b/ush/python/pygfs/task/ensemble_center.py @@ -92,8 +92,8 @@ def initialize(self) -> None: logger.info(f"Staging JEDI fix files from {self.task_config.JEDI_FIX_YAML}") jedi_fix_dict = parse_j2yaml(self.task_config.JEDI_FIX_YAML, self.task_config) FileHandler(jedi_fix_dict).sync() - logger.debug(f"JEDI fix files:\n{pformat(jedi_fix_dict)}") - + logger.debug(f"JEDI fix files:\n{pformat(jedi_fix_dict)}") + # Stage background and increment files logger.info(f"Staging background and increment files from {self.task_config.JEDI_BKG_INC_YAML}") fh_dict = parse_j2yaml(self.task_config.JEDI_BKG_INC_YAML, self.task_config) @@ -136,19 +136,18 @@ def finalize(self) -> None: # Initialize FileHandler to copy files to comrot cdate = to_fv3time(self.task_config.current_cycle).replace('.', '_') - anl_prefix = f"{self.task_config.COM_ATMOS_ANALYSIS_ENSSTAT}/enkf{self.task_config.APREFIX}" + anl_prefix = f"{self.task_config.COM_ATMOS_ANALYSIS_ENSSTAT}/enkf{self.task_config.APREFIX}" fh_dict = {'copy': []} cdate = to_fv3time(self.task_config.current_cycle).replace('.', '_') for fh in self.task_config.IAUFHRS: if fh == 6: for itile in range(6): fh_dict['copy'].append([f"{self.task_config.DATA}/catmi{format(fh, '03')}.tile{itile+1}.nc", - f"{anl_prefix}cubed_sphere_grid_catminc.tile{itile+1}.nc"]) + f"{anl_prefix}cubed_sphere_grid_catminc.tile{itile+1}.nc"]) else: for itile in range(6): fh_dict['copy'].append([f"{self.task_config.DATA}/catmi{format(fh, '03')}.tile{itile+1}.nc", f"{anl_prefix}/catmi{format(fh, '03')}.tile{itile+1}.nc"]) # Move files - FileHandler(fh_dict).sync() - + FileHandler(fh_dict).sync()