Newer
Older
from earthdiagnostics.diagnostic import (
Diagnostic,
DiagnosticOption,
DiagnosticDomainOption,
DiagnosticVariableListOption,
DiagnosticIntOption,
)
class SelectLevels(Diagnostic):
"""
Parameters
----------
data_manager: DataManager
startdate: str
member: int
chunk: init
domain: ModellingRealm
variable: str
grid: str or None
first_level: int
last_level: int
"Diagnostic alias for the configuration file"
def __init__(
self,
data_manager,
startdate,
member,
chunk,
domain,
variable,
grid,
first_level,
last_level,
):
Diagnostic.__init__(self, data_manager)
self.startdate = startdate
self.member = member
self.chunk = chunk
self.variable = variable
self.domain = domain
self.grid = grid
self.box = Box(False)
self.box.min_depth = first_level
self.box.max_depth = last_level
return (
"Select levels Startdate: {0.startdate} Member: {0.member} "
"Chunk: {0.chunk} Variable: {0.domain}:{0.variable} "
"Levels: {0.box.min_depth}-{0.box.max_depth} "
"Grid: {0.grid}".format(self)
)
if self._different_type(other):
return False
return (
self.startdate == other.startdate
and self.member == other.member
and self.chunk == other.chunk
and self.domain == other.domain
and self.variable == other.variable
and self.box == other.box
and self.grid == self.grid
)
@classmethod
def generate_jobs(cls, diags, options):
"""
:param diags: Diagnostics manager class
:type diags: Diags
:param options: domain,variables,grid
:type options: list[str]
:return:
"""
options_available = (
DiagnosticDomainOption(),
DiagnosticVariableListOption(
diags.data_manager.config.var_manager, "variables"
DiagnosticIntOption("first_level"),
DiagnosticIntOption("last_level"),
DiagnosticOption("grid", ""),
options = cls.process_options(options, options_available)
job_list = list()
chunk_list = diags.config.experiment.get_chunk_list()
for startdate, member, chunk in chunk_list:
job_list.append(
SelectLevels(
diags.data_manager,
startdate,
member,
chunk,
options["domain"],
var,
options["grid"],
options["first_level"],
options["last_level"],
)
)
self.domain,
self.variable,
self.startdate,
self.member,
self.chunk,
grid=self.grid,
to_modify=True,
self.domain,
self.variable,
self.startdate,
self.member,
self.chunk,
grid=self.grid,
handler = Utils.open_cdf(self.variable_file.local_file)
var_name = ""
if var in handler.variables:
var_name = var
continue
handler.close()
input=self.variable_file.local_file,
output=temp,
options="-O -d {1},{0.min_depth},{0.max_depth}".format(
self.box, var_name
),
@staticmethod
def _create_var(var_name, var_values, source, destiny):
var_name, old_var.dtype, dimensions=(var_name,)
)
new_var[:] = var_values
Utils.copy_attributes(new_var, old_var)
if vertices_name in source.variables:
var_vertices = source.variables[vertices_name]
vertices_values = var_vertices[0:1, ...]
else:
vertices_values = var_vertices[:, 0:1, :]
vertices_name,
var_vertices.dtype,
dimensions=(var_name, "vertices"),
new_lat_vertices[:] = vertices_values
Utils.copy_attributes(new_lat_vertices, var_vertices)