Wait for transform() to run using future.complete()

simonw · Jan 25, 2024 · 1a0e0ab · 1a0e0ab
1 parent 1d53b13
commit 1a0e0ab
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/datasette_upload_csvs/__init__.py b/datasette_upload_csvs/__init__.py
@@ -205,9 +205,10 @@ def transform_columns(conn):
                 database = sqlite_utils.Database(conn)
                 database[table_name].transform(types=tracker.types)
 
-            asyncio.run_coroutine_threadsafe(
+            future = asyncio.run_coroutine_threadsafe(
                 db.execute_write_fn(transform_columns), event_loop
             )
+            future.result()
         except Exception as error:
 
             def insert_error(conn):