update interpolate

src/ai_models/inputs/interpolate.py

@@ -6,6 +6,7 @@
 # nor does it submit to any jurisdiction.
 
 import logging
+from functools import lru_cache
 
 import earthkit.data as ekd
 import earthkit.regrid as ekr
@@ -15,29 +16,74 @@
 LOG = logging.getLogger(__name__)
 
 
+@lru_cache(maxsize=None)
+def ll_0p25():
+    return dict(
+        latitudeOfFirstGridPointInDegrees=90,
+        longitudeOfFirstGridPointInDegrees=0,
+        latitudeOfLastGridPointInDegrees=-90,
+        longitudeOfLastGridPointInDegrees=359.75,
+        iDirectionIncrementInDegrees=0.25,
+        jDirectionIncrementInDegrees=0.25,
+        Ni=1440,
+        Nj=721,
+        gridType="regular_ll",
+    )
+
+
+@lru_cache(maxsize=None)
+def gg_n320():
+    import eccodes
+
+    sample = None
+    result = {}
+    try:
+        sample = eccodes.codes_new_from_samples("reduced_gg_pl_320_grib2", eccodes.CODES_PRODUCT_GRIB)
+
+        for key in ("N", "Ni", "Nj"):
+            result[key] = eccodes.codes_get(sample, key)
+
+        for key in (
+            "latitudeOfFirstGridPointInDegrees",
+            "longitudeOfFirstGridPointInDegrees",
+            "latitudeOfLastGridPointInDegrees",
+            "longitudeOfLastGridPointInDegrees",
+        ):
+            result[key] = eccodes.codes_get_double(sample, key)
+
+        pl = eccodes.codes_get_long_array(sample, "pl")
+        result["pl"] = pl.tolist()
+        result["gridType"] = "reduced_gg"
+
+        return result
+
+    finally:
+        if sample is not None:
+            eccodes.codes_release(sample)
+
+
+METADATA = {"N320": gg_n320}
+
+
 class Interpolate:
-    def __init__(self, grid, source, metadata):
-        self.grid = list(grid) if isinstance(grid, tuple) else grid
+    def __init__(self, *, source, target):
+        self.target = list(target) if isinstance(target, tuple) else target
         self.source = list(source) if isinstance(source, tuple) else source
-        self.metadata = metadata
-
-        self._reduced_gg = metadata.get("gridType") == "reduced_gg"
 
     def __call__(self, ds):
         tmp = temp_file()
 
         out = ekd.new_grib_output(tmp.path)
-
-        result = []
+        out2 = ekd.new_grib_output("interpolated.grib2")
         for f in tqdm.tqdm(ds, delay=0.5, desc="Interpolating", leave=False):
-            data = ekr.interpolate(f.to_numpy(), dict(grid=self.source), dict(grid=self.grid))
-            out.write(data, template=f, **self.metadata)
+            data = ekr.interpolate(f.to_numpy(), dict(grid=self.source), dict(grid=self.target))
+            # result.append(f.clone(values=data, **METADATA[self.target]()))
+            out2.write(data, template=f, metadata=METADATA[self.target]())
+            out.write(data, template=f, metadata=METADATA[self.target]())
 
         out.close()
 
         result = ekd.from_source("file", tmp.path)
         result._tmp = tmp
 
-        print("Interpolated data", tmp.path)
-
         return result