fixes to cornflowclient + tests for WindProblem

cornflow-dags/DAG/sudoku/schemas/solution_checks.json

@@ -0,0 +1,7 @@
+{
+    "$schema": "http://json-schema.org/schema#",
+    "type": "object",
+    "properties": {
+    },
+    "required": []
+}

cornflow-dags/requirements.txt

@@ -16,7 +16,7 @@ ortools
 pyomo
 tsplib95<=0.7.1
 hackathonbaobab2020[solvers]
-git+ssh://git@github.com/pchtsp/windenergybattery.git@article_case_validation#egg=windenergybattery
+git+ssh://git@github.com/baobabsoluciones/windenergybattery.git@main#egg=windenergybattery
 networkx
 
 # quarto and reports:

cornflow-dags/tests/test_dags.py

@@ -209,6 +209,38 @@ def test_report(self):
         )
 
 
+class WindProblem(BaseDAGTests.SolvingTests):
+    def setUp(self):
+        super().setUp()
+        from DAG.wind_problem import WindEnergyBattery
+
+        self.app = WindEnergyBattery()
+
+    @patch("cornflow_client.airflow.dag_utilities.connect_to_cornflow")
+    def test_complete_report(self, connectCornflow, config=None):
+        config = config or self.config
+        config = dict(**config, report=dict(name="report"))
+        tests = self.app.test_cases
+        for test_case in tests:
+            instance_data = test_case.get("instance")
+            solution_data = test_case.get("solution", None)
+            if solution_data is None:
+                solution_data = dict(solution_node_values=[])
+
+            mock = Mock()
+            mock.get_data.return_value = dict(
+                data=instance_data, solution_data=solution_data
+            )
+            mock.get_results.return_value = dict(config=config, state=1)
+            mock.create_report.return_value = dict(id=1)
+            connectCornflow.return_value = mock
+            dag_run = Mock()
+            dag_run.conf = dict(exec_id="exec_id")
+            cf_report(app=self.app, secrets="", dag_run=dag_run)
+            mock.create_report.assert_called_once()
+            mock.put_one_report.assert_called_once()
+
+
 class Tsp(BaseDAGTests.SolvingTests):
     def setUp(self):
         super().setUp()

libs/client/cornflow_client/airflow/dag_utilities.py

@@ -386,8 +386,8 @@ def my_try_to_save(state):
         # maybe all of this should be abstracted inside the app?
         # maybe the app should return an Experiment?
         experiment = app.get_solver(app.get_default_solver_name())
-        my_experiment = experiment(
-            app.instance(input_data), app.solution(solution_data)
+        my_experiment = experiment.from_dict(
+            dict(instance=input_data, solution=solution_data)
         )
 
         print(f"Preparing to write the report: {report_name}")