feat(process): Use upload_graph_to_sparql_endpoint into the default process type

cubicweb_rodolf/sobjects/process_type_registry.py

@@ -2,5 +2,4 @@
 from rdflib import Graph
 
 from cubicweb.appobject import AppObject
-from cubicweb import Binary
 
@@ -6,5 +5,8 @@
 
-from cubicweb_rodolf.process_helpers import get_graph_from_url
+from cubicweb_rodolf.process_helpers import (
+    get_graph_from_url,
+    upload_graph_to_sparql_endpoint,
+)
 from cubicweb_rodolf.schema import ImportProcess
 
 
@@ -14,5 +16,6 @@
 
     def __call__(self, import_process: ImportProcess, log: logging.Logger) -> Graph:
         import_recipe = import_process.import_recipe[0]
+        import_procedure = import_process.import_procedure[0]
         dataservice = import_recipe.dataservice[0]
         graph = get_graph_from_url(dataservice.data_url, log)
@@ -17,3 +20,10 @@
         dataservice = import_recipe.dataservice[0]
         graph = get_graph_from_url(dataservice.data_url, log)
+        dataset_file = self._cw.create_entity(
+            "File",
+            title=f"Graph file for ImportProcess#{import_process.eid}",
+            data=Binary(graph.serialize(format="ttl").encode("utf8")),
+            data_name=f"data_ImportProcess_{import_process.eid}.ttl",
+            data_format="text/turtle",
+        )
         import_process.cw_set(
@@ -19,10 +29,11 @@
         import_process.cw_set(
-            has_output_dataset=self._cw.create_entity(
-                "File",
-                title=f"Graph file for ImportProcess#{import_process.eid}",
-                data=Binary(graph.serialize(format="ttl").encode("utf8")),
-                data_name=f"data_ImportProcess_{import_process.eid}.ttl",
-                data_format="text/turtle",
-            )
+            has_output_dataset=dataset_file,
+        )
+        upload_graph_to_sparql_endpoint(
+            import_procedure,
+            graph,
+            import_recipe.graph_uri,
+            dataset_file.data_name,
+            log,
         )
         return graph