defaults.py

Go to the documentation of this file.

 
 
import datetime
import logging
import os
 
import ehratm.syspaths
 
class Defaults(object):
 
    def __init__(self):
 
 
 
        self._SYSPATHS = ehratm.syspaths.SysSpecificPaths()
 
        self._LOG_LEVEL = logging.WARNING
 
 
        #----------------------------------
 
        self._ECMWF_SFC_UNGRIB_PREFIX = 'ECMWF_SFC'
        self._ECMWF_ML_UNGRIB_PREFIX = 'ECMWF_ML'
 
        # This value is forced by calc_ecmwf_p.exe - don't change it
        self._ECMWF_PRES_UNGRIB_PREFIX = 'PRES'
 
        self._GFS_UNGRIB_PREFIX = 'GFS'
 
        self._MAX_GRIB_INPUTS = 2
 
        self._WRF_SPINUP_HOURS = 6
 
 
        self._MAX_DOM_SUPPORTED = 7
 
      
        self._NUM_MPI_TASKS = 0    # 0 indicates serial, no MPI usage
        self._MAX_MPI_TASKS = 16  
 
        self._NUM_OPENMP_THREADS = 0    # 0 indicates serial, no OpenMP usage
        self._MAX_OPENMP_THREADS = 64
 
 
        # A couple of values for SRM production
        self._SRM_MULTIPLIER = 1.0
        self._SRM_COMPRESS = False
 
 
    
 
    def log_level(self):
        return self._LOG_LEVEL
 
 
    def workflow_name(self):
 
        """
        Return a name ehratmwf_YYYYMMDD_hhmmss.xxx
        """
 
        return 'ehratmwf_' + \
                datetime.datetime.utcnow().strftime('%Y%m%d_%H%M%S.%f')
 
    def ecmwf_sfc_ungrib_prefix(self):
        return self._ECMWF_SFC_UNGRIB_PREFIX
 
    def ecmwf_ml_ungrib_prefix(self):
        return self._ECMWF_ML_UNGRIB_PREFIX
 
    def ecmwf_pres_ungrib_prefix(self):
        return self._ECMWF_PRES_UNGRIB_PREFIX
 
    def gfs_ungrib_prefix(self):
        return self._GFS_UNGRIB_PREFIX
 
    def max_grib_inputs(self):
        return self._MAX_GRIB_INPUTS
 
    def wrf_spinup_hours(self):
        return self._WRF_SPINUP_HOURS
 
    def max_dom_supported(self):
        return self._MAX_DOM_SUPPORTED
 
    def num_mpi_tasks(self):
        # Returns default number of MPI tasks
        return self._NUM_MPI_TASKS
 
    def max_mpi_tasks(self):
        return self._MAX_MPI_TASKS
 
    def num_openmp_threads(self):
        # Returns default number of OpenMP threads
        return self._NUM_OPENMP_THREADS
 
    def max_openmp_threads(self):
        return self._MAX_OPENMP_THREADS
 
    def srm_multiplier(self):
        return self._SRM_MULTIPLIER
 
    def srm_compress(self):
        return self._SRM_COMPRESS
 
    #----------------------------------------------
 
    # These get their values by using methods in the ehratm.syspaths class
    def wpswrf_distro_path(self):
        return self._SYSPATHS.wpswrf_distro_path()
 
    def wps_geog_data_dir(self):
        return self._SYSPATHS.wps_geog_data_dir()
 
    def flexwrf_distro_path(self):
        return self._SYSPATHS.flexwrf_distro_path()
 
    def srm_flexpart2ctbt_path(self):
        return self._SYSPATHS.srm_flexpart2ctbt_path()
 
    def mpirun_path(self):
        return self._SYSPATHS.mpirun_path()
 
    def working_scratch_rootdir(self):
        return self._SYSPATHS.working_scratch_rootdir()
 
    def workflow_rootdir(self):
        return self._SYSPATHS.workflow_rootdir()
 
    def vtable_ecmwf_ml(self):
        return self._SYSPATHS.vtable_ecmwf_ml()
 
    def vtable_ecmwf_sfc(self):
        return self._SYSPATHS.vtable_ecmwf_sfc()
 
    def ecmwf_coeffs(self):
        return self._SYSPATHS.ecmwf_coeffs()
 
    def ecmwf_metgrid_tbl(self):
        return self._SYSPATHS.ecmwf_metgrid_tbl()
    #-------------------------------------------------