@@ -243,6 +243,7 @@ def load_sample_data(
243243 ).scalar ()
244244 except sa .exc .ProgrammingError :
245245 table_exists = False
246+ session .rollback ()
246247
247248 if table_exists :
248249 logger .info (f"GerryDB view { view .table_name } already exists." )
@@ -267,8 +268,8 @@ def load_sample_data(
267268 sa .text ("select 1 from gerrydbtable where name = :name limit 1" ),
268269 {"name" : view .gerrydb_table_name },
269270 ).scalar ()
271+ session .rollback ()
270272 if gerrydb_table_exists :
271- session .rollback ()
272273 logger .info (f"GerryDB table { view .gerrydb_table_name } already exists." )
273274 else :
274275 _create_shatterable_gerrydb_view (session = session , ** view .model_dump ())
@@ -282,8 +283,8 @@ def load_sample_data(
282283 ),
283284 {"slug" : view .districtr_map_slug },
284285 ).one_or_none ()
286+ session .rollback ()
285287 if districtr_map_exists :
286- session .rollback ()
287288 u = districtr_map_exists .uuid
288289 logger .info (f"Districtr map { view .districtr_map_slug } already exists." )
289290 else :
@@ -304,7 +305,6 @@ def load_sample_data(
304305 if u is not None :
305306 logger .info (f"Created districtr map with UUID { u } " )
306307 else :
307- session .rollback ()
308308 session = next (get_session ())
309309 u = session .exec (
310310 sa .select (DistrictrMap .uuid ).where ( # pyright: ignore
@@ -331,3 +331,4 @@ def load_sample_data(
331331 districtr_map_slug = group .districtr_map_slug ,
332332 group_slug = group .group_slug ,
333333 )
334+ session .commit ()
0 commit comments