extra check before column creation

2017-09-24 10:41:08 +03:00
parent db9c41a090
commit 1fd19f37b9
2 changed files with 5 additions and 3 deletions
@@ -247,7 +247,8 @@ class Table(object):
            with self.db.lock:
                self._threading_warn()
                for column in columns:
-                    self.db.op.add_column(self.name, column, self.db.schema)
+                    if not self.has_column(column.name):
+                        self.db.op.add_column(self.name, column, self.db.schema)
                self._reflect_table()

    def _sync_columns(self, row, ensure, types=None):