diff --git a/cognee/infrastructure/databases/vector/pgvector/create_db_and_tables.py b/cognee/infrastructure/databases/vector/pgvector/create_db_and_tables.py
index dd029de0a..99d53d698 100644
--- a/cognee/infrastructure/databases/vector/pgvector/create_db_and_tables.py
+++ b/cognee/infrastructure/databases/vector/pgvector/create_db_and_tables.py
@@ -7,9 +7,8 @@ async def create_db_and_tables():
     vector_engine = get_vector_engine()
 
     if vector_config.vector_db_provider == "pgvector":
+        vector_engine.create_database()
         async with vector_engine.engine.begin() as connection:
-            if len(Base.metadata.tables.keys()) > 0:
-                await connection.run_sync(Base.metadata.create_all)
             await connection.execute(text("CREATE EXTENSION IF NOT EXISTS vector;"))