create plugin label in provenance data

CHANGELOG.md

@@ -13,6 +13,7 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/) and this p
 ### Changed
 
 - output graph label derived from input graph
+- create plugin label in provenance data
 
 ## [1.0.0rc1] 2024-08-28
 

cmem_plugin_reason/plugin_reason.py

@@ -498,7 +498,7 @@ def _execute(self, context: ExecutionContext) -> None:
             else:
                 valid_profiles = validate_profiles(self, graphs)
             post_profiles(self, valid_profiles)
-        post_provenance(self, get_provenance(self, context))
+        post_provenance(self, get_provenance(self, "Reason", context))
 
         if self.import_result or not self.import_ontology:
             setup_cmempy_user_access(context.user)

cmem_plugin_reason/plugin_validate.py

@@ -253,7 +253,7 @@ def _execute(self, context: ExecutionContext) -> Entities | None:
             setup_cmempy_user_access(context.user)
             send_result(self.output_graph_iri, Path(self.temp) / "output.ttl")
             setup_cmempy_user_access(context.user)
-            post_provenance(self, get_provenance(self, context))
+            post_provenance(self, get_provenance(self, "Validate", context))
 
         valid_profiles = (
             self.add_profiles(validate_profiles(self, graphs)) if self.validate_profile else []

cmem_plugin_reason/utils.py

@@ -136,18 +136,19 @@ def post_provenance(plugin: WorkflowPlugin, prov: dict | None) -> None:
         post_update(query=insert_query)
 
 
-def get_provenance(plugin: WorkflowPlugin, context: ExecutionContext) -> dict | None:
+def get_provenance(
+    plugin: WorkflowPlugin, label_plugin: str, context: ExecutionContext
+) -> dict | None:
     """Get provenance information"""
     plugin_iri = (
         f"http://dataintegration.eccenca.com/{context.task.project_id()}/{context.task.task_id()}"
     )
     project_graph = f"http://di.eccenca.com/project/{context.task.project_id()}"
 
     type_query = f"""
-        SELECT ?type ?label {{
+        SELECT ?type {{
             GRAPH <{project_graph}> {{
                 <{plugin_iri}> a ?type .
-                <{plugin_iri}> <http://www.w3.org/2000/01/rdf-schema#label> ?label .
                 FILTER(STRSTARTS(STR(?type), "https://vocab.eccenca.com/di/functions/"))
             }}
         }}
@@ -160,7 +161,6 @@ def get_provenance(plugin: WorkflowPlugin, context: ExecutionContext) -> dict |
     except IndexError:
         plugin.log.warning("Could not add provenance data to output graph.")
         return None
-    plugin_label = result["results"]["bindings"][0]["label"]["value"]
 
     param_split = (
         plugin_type.replace(
@@ -180,11 +180,12 @@ def get_provenance(plugin: WorkflowPlugin, context: ExecutionContext) -> dict |
     """
 
     new_plugin_iri = f'{"_".join(plugin_iri.split("_")[:-1])}_{token_hex(8)}'
+    label = f"{label_plugin} plugin"
     result = json.loads(post_select(query=parameter_query))
 
     prov = {
         "plugin_iri": new_plugin_iri,
-        "plugin_label": plugin_label,
+        "plugin_label": label,
         "plugin_type": plugin_type,
         "parameters": {},
     }