Skip to content

Commit

Permalink
Catcheo la excepción en la función de restauración de un catálogo par…
Browse files Browse the repository at this point in the history
…a que imprima el error y siga adelante con las otras.
  • Loading branch information
abenassi committed Oct 1, 2019
1 parent ccddd6e commit b01c2c8
Showing 1 changed file with 16 additions and 10 deletions.
26 changes: 16 additions & 10 deletions pydatajson/federation.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@

from __future__ import print_function, unicode_literals
import logging
import traceback
from ckanapi.errors import NotFound, CKANAPIError

from pydatajson.constants import REQUESTS_TIMEOUT, DEFAULT_TIMEZONE
Expand Down Expand Up @@ -748,15 +749,20 @@ def restore_catalog_to_ckan(catalog, origin_portal_url, destination_portal_url,
for org in org_list:
print("Restaurando organizacion {}".format(org))

response = origin_portal.action.organization_show(
id=org, include_datasets=True)
datasets = [package['id'] for package in response['packages']]
pushed_datasets = restore_organization_to_ckan(
catalog, org, destination_portal_url, apikey,
dataset_list=datasets, download_strategy=download_strategy,
generate_new_access_url=generate_new_access_url,
origin_tz=origin_tz, dst_tz=dst_tz
)
res[org] = pushed_datasets
try:
response = origin_portal.action.organization_show(
id=org, include_datasets=True)
datasets = [package['id'] for package in response['packages']]

pushed_datasets = restore_organization_to_ckan(
catalog, org, destination_portal_url, apikey,
dataset_list=datasets, download_strategy=download_strategy,
generate_new_access_url=generate_new_access_url,
origin_tz=origin_tz, dst_tz=dst_tz
)
res[org] = pushed_datasets
except Exception as e:
print(e)
print(traceback.print_exc())

return res

0 comments on commit b01c2c8

Please sign in to comment.