diff --git a/langchain_postgres/v2/engine.py b/langchain_postgres/v2/engine.py index 219717e..608dc65 100644 --- a/langchain_postgres/v2/engine.py +++ b/langchain_postgres/v2/engine.py @@ -256,7 +256,7 @@ async def _ainit_vectorstore_table( nullable = "NOT NULL" if not column["nullable"] else "" query += f',\n"{column["name"]}" {column["data_type"]} {nullable}' if store_metadata: - query += f""",\n"{metadata_json_column}" JSON""" + query += f""",\n"{metadata_json_column}" JSONB""" query += "\n);" async with self._pool.connect() as conn: