diff --git a/lightrag/kg/postgres_impl.py b/lightrag/kg/postgres_impl.py index 6144e835..1642c04b 100644 --- a/lightrag/kg/postgres_impl.py +++ b/lightrag/kg/postgres_impl.py @@ -2350,9 +2350,9 @@ class PGVectorStorage(BaseVectorStorage): ON CONFLICT DO NOTHING """ - # AsyncPG requires positional parameters as a list in order - values = [row_dict[col] for col in columns] - await db.execute(insert_query, *values) + # Construct dict for execute() method + values = {col: row_dict[col] for col in columns} + await db.execute(insert_query, values) migrated_count += len(rows) logger.info(