feat: Add check if the language is already an iri

Author: kovalch

ckanext/dcatapchharvest/profiles.py

@@ -866,9 +866,16 @@ def graph_from_dataset(self, dataset_dict, dataset_ref):  # noqa
         # Languages
         languages = dataset_dict.get('language', [])
         for lang in languages:
-            uri = language_uri_map.get(lang)
-            if uri:
-                g.add((dataset_ref, DCT.language, URIRef(uri)))
+            if lang.startswith('http://') or lang.startswith('https://'):
+                # lang is already a full IRI, use directly
+                g.add((dataset_ref, DCT.language, URIRef(lang)))
+            else:
+                uri = language_uri_map.get(lang)
+                if uri:
+                    g.add((dataset_ref, DCT.language, URIRef(uri)))
+                else:
+                    log.debug("Language '{}' not found in"
+                              " language_uri_map".format(lang))
 
         # Relations
         if dataset_dict.get('relations'):
@@ -1035,6 +1042,20 @@ def graph_from_dataset(self, dataset_dict, dataset_ref):  # noqa
                 if uri:
                     g.add((distribution, DCT.language, URIRef(uri)))
 
+            # Language
+            languages = resource_dict.get('language', [])
+            for lang in languages:
+                if lang.startswith('http://') or lang.startswith('https://'):
+                    # lang is already a full IRI, use directly
+                    g.add((distribution, DCT.language, URIRef(lang)))
+                else:
+                    uri = language_uri_map.get(lang)
+                    if uri:
+                        g.add((distribution, DCT.language, URIRef(uri)))
+                    else:
+                        log.debug("Language '{}' not found in"
+                                  " language_uri_map".format(lang))
+
             # Download URL & Access URL
             download_url = resource_dict.get('download_url')
             if download_url:
@@ -1407,12 +1428,19 @@ def graph_from_dataset(self, dataset_dict, dataset_ref):
                 distribution, DCT.description, "description", resource_dict
             )  # noqa
 
-            #  Language
+            # Language
             languages = resource_dict.get('language', [])
             for lang in languages:
-                uri = language_uri_map.get(lang)
-                if uri:
-                    g.add((distribution, DCT.language, URIRef(uri)))
+                if lang.startswith('http://') or lang.startswith('https://'):
+                    # lang is already a full IRI, use directly
+                    g.add((distribution, DCT.language, URIRef(lang)))
+                else:
+                    uri = language_uri_map.get(lang)
+                    if uri:
+                        g.add((distribution, DCT.language, URIRef(uri)))
+                    else:
+                        log.debug("Language '{}' not found in"
+                                  " language_uri_map".format(lang))
 
             # Download URL & Access URL
             self.download_access_url(resource_dict, distribution, g)