wip build zarr

ecml_tools/create/functions/accumulations.py

@@ -54,7 +54,7 @@ def accumulations(context, dates, **request):
         r = normalise_time_to_hours(r)
 
         if DEBUG:
-            print(f"✅ load_source({source_name},  {r}")
+            print(f"load_source({source_name},  {r}")
         ds = ds + load_source(source_name, **r)
     return ds
 

ecml_tools/create/functions/constants.py

@@ -56,10 +56,12 @@ def normalise_time_to_hours(r):
 
 
 def constants(context, dates, **request):
+    param = request["param"]
+
     template = get_template_field(request)
 
     print(f"✅ load_source(constants, {template}, {request}")
-    return load_source("constants", source_or_dataset=template, **request)
+    return load_source("constants", source_or_dataset=template, date=dates, param=param)
 
 
 execute = constants

ecml_tools/create/input.py

@@ -99,7 +99,9 @@ def _build_coords(self):
         assert isinstance(self.owner.context, Context), type(self.owner.context)
         assert isinstance(self.owner, Result), type(self.owner)
         assert hasattr(self.owner, "context"), self.owner
+        assert hasattr(self.owner, "datasource"), self.owner
         assert hasattr(self.owner, "get_cube"), self.owner
+        self.owner.datasource
 
         from_data = self.owner.get_cube().user_coords
         from_config = self.owner.context.order_by
@@ -423,6 +425,7 @@ def __repr__(self):
 
 
 def import_function(name):
+    name = name.replace("-", "_")
     here = os.path.dirname(__file__)
     path = os.path.join(here, "functions", f"{name}.py")
     spec = importlib.util.spec_from_file_location(name, path)
@@ -434,6 +437,7 @@ def import_function(name):
 
 
 def is_function(name):
+    name = name.replace("-", "_")
     here = os.path.dirname(__file__)
     path = os.path.join(here, "functions", f"{name}.py")
     return os.path.exists(path)

ecml_tools/create/loaders.py

@@ -146,7 +146,7 @@ def __init__(self, config, **kwargs):
 
         self.groups = build_groups(*self.main_config.loop)
         print("✅ GROUPS")
-        print(self.groups, self.main_config.loop)
+        # print(self.groups, self.main_config.loop)
 
         self.output = build_output(self.main_config.output, parent=self)
         self.input = self.build_input()