diff --git a/cmem_plugin_databus/utils.py b/cmem_plugin_databus/utils.py index 748bfa6..d92695f 100644 --- a/cmem_plugin_databus/utils.py +++ b/cmem_plugin_databus/utils.py @@ -393,7 +393,6 @@ def fetch_facets_options( def fetch_databus_files(endpoint: str, artifact: str, version: str, file_format: str): """fetch databus file name based of artifact, version and format on a given databus instance""" - query = f"""PREFIX rdfs: PREFIX rdf: PREFIX dcat: @@ -401,29 +400,14 @@ def fetch_databus_files(endpoint: str, artifact: str, version: str, file_format: PREFIX dcv: PREFIX databus: SELECT DISTINCT ?file ?version ?artifact ?license ?size ?format ?compression - (GROUP_CONCAT(DISTINCT ?var; SEPARATOR=', ') AS ?variant) ?preview WHERE + (GROUP_CONCAT(DISTINCT ?var; SEPARATOR=', ') AS ?variant) ?preview WHERE {{ GRAPH ?g {{ ?dataset databus:artifact <{artifact}> . - {{ - ?distribution dct:hasVersion ?version {{ - SELECT (?v as ?version) {{ - GRAPH ?g2 {{ - ?dataset databus:artifact <{artifact}> . - ?dataset dct:hasVersion ?v . - }} - }} ORDER BY DESC (STR(?version)) LIMIT 1 - }} - }} - UNION {{ ?distribution '{version}' . }} - {{ - ?distribution ?c0 . - VALUES ?c0 {{ - '{file_format}' - }} - }} + {{ ?distribution + '{file_format}' . }} ?dataset dcat:distribution ?distribution . ?distribution databus:file ?file . ?distribution databus:formatExtension ?format . @@ -432,7 +416,7 @@ def fetch_databus_files(endpoint: str, artifact: str, version: str, file_format: ?dataset dct:hasVersion ?version . ?dataset databus:artifact ?artifact . OPTIONAL - {{ ?distribution ?p ?var. ?p rdfs:subPropertyOf databus:contentVariant . }} + {{ ?distribution ?p ?var. ?p rdfs:subPropertyOf databus:contentVariant . }} OPTIONAL {{ ?distribution dcat:byteSize ?size . }} }} }}