fix(logic): ckan versioning;

- DS fields for ckan versions.
JVickery-TBS · Jul 16, 2024 · 3263bab · 3263bab
1 parent 669930e
commit 3263bab
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/ckanext/xloader/loader.py b/ckanext/xloader/loader.py
@@ -178,8 +178,11 @@ def load_csv(csv_filepath, resource_id, mimetype='text/csv', logger=None):
         existing = datastore_resource_exists(resource_id)
         existing_info = {}
         if existing:
-            ds_info = p.toolkit.get_action('datastore_info')({'ignore_auth': True}, {'id': resource_id})
-            existing_fields = ds_info.get('fields', [])
+            if p.toolkit.check_ckan_version(max_version='2.9'):
+                existing_fields = existing.get('fields', [])
+            else:
+                ds_info = p.toolkit.get_action('datastore_info')({'ignore_auth': True}, {'id': resource_id})
+                existing_fields = ds_info.get('fields', [])
             existing_info = dict((f['id'], f['info'])
                                  for f in existing_fields
                                  if 'info' in f)