copyed
"""
_src_cols = _dst_cols = column_list
- _write_hook = None
condition = ' and '.join(cond_list)
if self.conf.skip_fields:
if self.encoding_validator:
def _write_hook(obj, data):
return self.encoding_validator.validate_copy(data, _src_cols)
+ else:
+ _write_hook = None
return skytools.full_copy(tablename, src_curs, dst_curs, _src_cols,
condition, self.table_name, _dst_cols,
curs.execute(q)
self.local_part, self.max_part = curs.fetchone()
if self.local_part is None or self.max_part is None:
- raise Exeption('Error loading part info')
+ raise Exception('Error loading part info')
# register handler class
__londiste_handlers__ = [PartHandler]