diff --git a/pgsqlite/pgsqlite.py b/pgsqlite/pgsqlite.py
index 18b2e1c..df2c652 100644
--- a/pgsqlite/pgsqlite.py
+++ b/pgsqlite/pgsqlite.py
@@ -181,6 +181,8 @@ def __init__(self, sqlite_filename: str, pg_conninfo: str, show_sample_data: boo
         self.max_import_concurrency = max_import_concurrency
         db = Database(self.sqlite_filename)
         self._tables = {t.name: ParsedTable(t) for t in db.tables}
+        if sys.platform == "win32":
+            asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
 
     @property
     def tables(self):