Add Intel MPI support #57

CHANGELOG.md

@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ### Changed
 
 - More optimal distribution of tiles on processors for cubed-sphere tile space.
+- Updates to scripting to allow for Intel MPI
 
 ### Fixed
 
@@ -43,9 +44,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - Moved external `GEOSgcm_GridComp` repository to under `GEOSldas/src/Components` for
   consistency with directory structure of GEOSgcm and GEOSadas  ([PR #27](https://github.com/GEOS-ESM/GEOSldas_GridComp/pull/27), [PR #30](https://github.com/GEOS-ESM/GEOSldas_GridComp/pull/30)).
-- Changed lenkf.j.template to python string ([PR #16](https://github.com/GEOS-ESM/GEOSldas_GridComp/pull/16)). 
+- Changed lenkf.j.template to python string ([PR #16](https://github.com/GEOS-ESM/GEOSldas_GridComp/pull/16)).
+
 
-
 -----------------------------
 
 ## [v1.0.1] - 2024-04-10

GEOSldas_App/ldas_setup

@@ -737,7 +737,7 @@ class LDASsetup:
            wemin_out = self.rqdExeInp['WEMIN_OUT']
 
 
-        tmp_f2g_file = tempfile.NamedTemporaryFile(delete=False) 
+        tmp_f2g_file = tempfile.NamedTemporaryFile(delete=False)
         cmd = self.bindir +'/preprocess_ldas.x c_f2g ' + tile + ' ' + self.domain_def.name + ' '+ self.out_path + ' ' + catchment_def + ' ' + exp_id + ' ' + _y4m2d2h2m2 + ' '+ dzsf + ' ' + tmp_f2g_file.name
 
         print ('Creating f2g file: '+ tmp_f2g_file.name +'....\n')
@@ -901,7 +901,7 @@ class LDASsetup:
              config['input']['shared']['agrid']      = 'C180'
              config['input']['shared']['ogrid']      = '1440x720'
              config['input']['shared']['omodel']     = 'data'
-           
+
            catch_obj = catchANDcn(config_obj = config)
            catch_obj.remap()
 
@@ -1367,6 +1367,8 @@ class LDASsetup:
         if self.GEOS_SITE == 'NAS':
           SBATCHQSUB = 'qsub'
 
+        DETECTED_MPI_STACK = "@MPI_STACK@"
+
         job_head = job_directive[self.GEOS_SITE]
         lenkf_str= (job_head+job_body).format(
                   SBATCHQSUB         = SBATCHQSUB,
@@ -1389,7 +1391,9 @@ class LDASsetup:
                   MY_LADAS_COUPLING  = str(self.ladas_coupling),
                   MY_ENSEMBLE_FORCING= self.rqdExeInp.get('ENSEMBLE_FORCING', 'NO').upper(),
                   MY_ADAS_EXPDIR     = self.adas_expdir,
-                  MY_EXPDIR          = self.expdir
+                  MY_EXPDIR          = self.expdir,
+                  DETECTED_MPI_STACK = DETECTED_MPI_STACK,
+                  BUILT_ON_SLES15    = str(self.BUILT_ON_SLES15).upper()
                   )
 
         with open('lenkf.j','wt') as fout :