Changeset View
Changeset View
Standalone View
Standalone View
swh/core/db/__init__.py
Show First 20 Lines • Show All 180 Lines • ▼ Show 20 Lines | def copy_to(self, items, tblname, columns, | ||||
try: | try: | ||||
with open(write_file, 'w') as f: | with open(write_file, 'w') as f: | ||||
for d in items: | for d in items: | ||||
if item_cb is not None: | if item_cb is not None: | ||||
item_cb(d) | item_cb(d) | ||||
line = [] | line = [] | ||||
for k in columns: | for k in columns: | ||||
try: | |||||
value = d.get(k, default_values.get(k)) | value = d.get(k, default_values.get(k)) | ||||
try: | |||||
line.append(escape(value)) | line.append(escape(value)) | ||||
except Exception as e: | except Exception as e: | ||||
logger.error( | logger.error( | ||||
'Could not escape value `%r` for column `%s`:' | 'Could not escape value `%r` for column `%s`:' | ||||
'Received exception: `%s`', | 'Received exception: `%s`', | ||||
value, k, e | value, k, e | ||||
) | ) | ||||
raise e from None | raise e from None | ||||
Show All 14 Lines |