Some refactoring

ecml_tools/create/functions/actions/constants.py

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

ecml_tools/create/functions/actions/opendap.py

@@ -13,7 +13,6 @@
 
 
 def opendap(context, dates, url_pattern, *args, **kwargs):
-
     all_urls = Pattern(url_pattern, ignore_missing_keys=True).substitute(
         *args, date=dates, **kwargs
     )
@@ -22,7 +21,6 @@ def opendap(context, dates, url_pattern, *args, **kwargs):
     levels = kwargs.get("level", kwargs.get("levelist"))
 
     for url in all_urls:
-
         print("URL", url)
         s = load_source("opendap", url)
         s = s.sel(

ecml_tools/create/functions/steps/rotate_winds.py

@@ -0,0 +1,15 @@
+# (C) Copyright 2024 ECMWF.
+#
+# This software is licensed under the terms of the Apache Licence Version 2.0
+# which can be obtained at http://www.apache.org/licenses/LICENSE-2.0.
+# In applying this licence, ECMWF does not waive the privileges and immunities
+# granted to it by virtue of its status as an intergovernmental organisation
+# nor does it submit to any jurisdiction.
+#
+
+
+def execute(context, input, **kwargs):
+    print("🧭", input, kwargs)
+    for f in input:
+        print(f)
+    return input