debugging stringified archival field in resources

ckanext/archiver/tasks.py

@@ -106,7 +106,8 @@ def update_resource(ckan_ini_filepath, resource_id, queue='bulk', force=False):
     # celery's task status.
     try:
         result = _update_resource(resource_id, queue, log, force)
-        return result
+        # serialized for Celery
+        return json.dumps(result)
     except Exception, e:
         if os.environ.get('DEBUG'):
             raise
@@ -288,8 +289,9 @@ def _update_resource(resource_id, queue, log, force):
         _save(Status.by_text('Archived successfully'), '', resource,
             download_result_mock['url_redirected_to'], download_result_mock, archive_result_mock)
 
-        # The return value is only used by tests. Serialized for Celery.
-        return json.dumps(dict(download_result_mock, **archive_result_mock))
+        #this used to be serialized to JSON string (supposedly for Celery). Moved the serialization to resource_update
+        #to avoid bugs because of stringified archival fields in resources
+        return dict(download_result_mock, **archive_result_mock)
         # endif: processing locally uploaded resource
 
 
@@ -365,8 +367,9 @@ def _update_resource(resource_id, queue, log, force):
     _save(Status.by_text('Archived successfully'), '', resource,
             download_result['url_redirected_to'], download_result, archive_result)
 
-    # The return value is only used by tests. Serialized for Celery.
-    return json.dumps(dict(download_result, **archive_result))
+    #this used to be serialized to JSON string (supposedly for Celery). Moved the serialization to resource_update
+    #to avoid bugs because of stringified archival fields in resources
+    return dict(download_result, **archive_result)
 
 
 def download(context, resource, url_timeout=30,