Fix version check

ckan · Dec 16, 2024 · 6bcf693 · 6bcf693
1 parent 0d64786
commit 6bcf693
Showing 1 changed file with 15 additions and 6 deletions.
diff --git a/ckanext/dcat/harvesters/base.py b/ckanext/dcat/harvesters/base.py
@@ -159,12 +159,21 @@ def _read_datasets_from_db(self, guid):
         '''
         Returns a database result of datasets matching the given guid.
         '''
-        datasets = model.Session.query(model.Package.id) \
-            .join(model.PackageExtra) \
-            .filter(model.PackageExtra.key == 'guid') \
-            .filter(model.PackageExtra.value == guid) \
-            .filter(model.Package.state == 'active') \
-            .all()
+        if toolkit.check_ckan_version(max_version="2.11.99"):
+            datasets = (
+                model.Session.query(model.Package.id)
+                .join(model.PackageExtra)
+                .filter(model.PackageExtra.key == "guid")
+                .filter(model.PackageExtra.value == guid)
+                .filter(model.Package.state == "active")
+                .all()
+            )
+        else:
+            datasets = (
+                model.Session.query(model.Package.id)
+                .filter(model.Package.extras["guid"] == f'"{guid}"')
+                .all()
+            )
 
         return datasets