port code to psycopg3

[nominatim.git] / src / nominatim_db / clicmd / refresh.py

diff --git a/src/nominatim_db/clicmd/refresh.py b/src/nominatim_db/clicmd/refresh.py
index 363bad7853431851264f53eab83be7f277e46e07..adc7ee656caa67004a402aadf66e467f477d4041 100644 (file)
--- a/src/nominatim_db/clicmd/refresh.py
+++ b/src/nominatim_db/clicmd/refresh.py
@@ -11,6 +11,7 @@ from typing import Tuple, Optional
 import argparse
 import logging
 from pathlib import Path
 import argparse
 import logging
 from pathlib import Path

+import asyncio

 
 from ..config import Configuration
 from ..db.connection import connect, table_exists
 
 from ..config import Configuration
 from ..db.connection import connect, table_exists


@@ -99,7 +100,7 @@ class UpdateRefresh:
                                            args.project_dir, tokenizer)
                 indexer = Indexer(args.config.get_libpq_dsn(), tokenizer,
                                   args.threads or 1)
                                            args.project_dir, tokenizer)
                 indexer = Indexer(args.config.get_libpq_dsn(), tokenizer,
                                   args.threads or 1)

-                indexer.index_postcodes()
+                asyncio.run(indexer.index_postcodes())

             else:
                 LOG.error("The place table doesn't exist. "
                           "Postcode updates on a frozen database is not possible.")
             else:
                 LOG.error("The place table doesn't exist. "
                           "Postcode updates on a frozen database is not possible.")