except OSError as exp:
errors.append(ex.CannotReadError(archive_path(name), exp))
else:
- filedata.append(UploadBulkData(fh,
- uf['upload_fmt'],
- uf['upload_null'],
- uf['null_rep'],
- archive_path(name),
- fmap['relation'],
- trim=uf['trim_upload']))
+ try:
+ filedata.append(UploadBulkData(fh,
+ uf['upload_fmt'],
+ uf['upload_null'],
+ uf['null_rep'],
+ archive_path(name),
+ fmap['relation'],
+ trim=uf['trim_upload']))
+ except core_ex.PGWUIError as exp:
+ relation = fmap['relation']
+ exp.color(map_description(name, relation),
+ name, relation)
+ errors.append(exp)
if errors:
raise core_ex.MultiError(errors)
return filedata