diff --git a/ckanext/xloader/cli.py b/ckanext/xloader/cli.py index 3df91124..53dee8a9 100644 --- a/ckanext/xloader/cli.py +++ b/ckanext/xloader/cli.py @@ -184,10 +184,13 @@ def _submit_resource(self, resource, user, indent=0): r=resource)) return dataset_ref = resource.get('package_name', resource['package_id']) - print('{indent}Submitting /dataset/{dataset}/resource/{r[id]}\n' - '{indent} url={r[url]}\n' - '{indent} format={r[format]}' - .format(dataset=dataset_ref, r=resource, indent=' ' * indent)) + print(u'{indent}Submitting /dataset/{dataset}/resource/{r[id]}\n' + u'{indent} url={url}\n' + u'{indent} format={format}' + .format(dataset=dataset_ref, + format=r['format'].decode('utf-8'), + url=r['url'].decode('utf-8'), + indent=' ' * indent)) data_dict = { 'resource_id': resource['id'], 'ignore_hash': True, diff --git a/ckanext/xloader/jobs.py b/ckanext/xloader/jobs.py index 68f3bc30..17d66592 100644 --- a/ckanext/xloader/jobs.py +++ b/ckanext/xloader/jobs.py @@ -158,7 +158,7 @@ def xloader_data_into_datastore_(input, job_dict): ) # fetch the resource data - logger.info(u'Fetching from: {0}'.format(url)) + logger.info(u'Fetching from: {0}'.format(url.decode('utf-8'))) try: headers = {} if resource.get('url_type') == 'upload':