diff --git a/database/database_table.py b/database/database_table.py index 8fa85da50f846529cf0c36996a4b460e9a695954..8f0e6d6b9e7f0afc21c5c4f1b62adb3f3e924ac5 100644 --- a/database/database_table.py +++ b/database/database_table.py @@ -241,7 +241,8 @@ class DatabaseTable(Table): bind = self.metadata.bind original_columns = list(self.columns) - query = ttable.insert().from_select(original_columns, select(original_columns)) + query = ttable.insert().from_select(original_columns, select(original_columns) + .where(self.c[settings.YEAR_COLUMN] == year)) bind.execute(query) return ttable