diff --git a/clickhouse_mysql/tablemigrator.py b/clickhouse_mysql/tablemigrator.py index 84f095e..07e0986 100644 --- a/clickhouse_mysql/tablemigrator.py +++ b/clickhouse_mysql/tablemigrator.py @@ -107,9 +107,9 @@ def __init__( self.where_clauses[db] = {} if os.path.isfile(where_file_name): - self.wheres[db][table] = open(where_file_name, 'r').read().strip("\n") + self.where_clauses[db][table] = open(where_file_name, 'r').read().strip("\n") else: - self.wheres[db][table] = where_file_name + self.where_clauses[db][table] = where_file_name # debug info logging.info("migration where clauses")