diff --git a/packages/components/nodes/vectorstores/Elasticsearch/Elasticsearch_Upsert.ts b/packages/components/nodes/vectorstores/Elasticsearch/Elasticsearch_Upsert.ts
index d3965786..a8ccd49a 100644
--- a/packages/components/nodes/vectorstores/Elasticsearch/Elasticsearch_Upsert.ts
+++ b/packages/components/nodes/vectorstores/Elasticsearch/Elasticsearch_Upsert.ts
@@ -50,7 +50,7 @@ class ElasicsearchUpsert_VectorStores extends ElasticSearchBase implements INode
             delete d.metadata.loc
         })
         // end of workaround
-        return super.init(nodeData, _, options, flattenDocs)
+        return super.init(nodeData, _, options, finalDocs)
     }
 }
 
diff --git a/packages/components/nodes/vectorstores/MongoDB/MongoDB_Existing.ts b/packages/components/nodes/vectorstores/MongoDB/MongoDB_Existing.ts
index 3cbb36b8..7b06814a 100644
--- a/packages/components/nodes/vectorstores/MongoDB/MongoDB_Existing.ts
+++ b/packages/components/nodes/vectorstores/MongoDB/MongoDB_Existing.ts
@@ -1,11 +1,10 @@
-import { ICommonObject, INode, INodeData } from '../../../src/Interface'
+import { Collection } from 'mongodb'
+import { MongoDBAtlasVectorSearch } from 'langchain/vectorstores/mongodb_atlas'
 import { Embeddings } from 'langchain/embeddings/base'
 import { VectorStore } from 'langchain/vectorstores/base'
 import { Document } from 'langchain/document'
-
 import { MongoDBSearchBase } from './MongoDBSearchBase'
-import { Collection } from 'mongodb'
-import { MongoDBAtlasVectorSearch } from 'langchain/vectorstores/mongodb_atlas'
+import { ICommonObject, INode, INodeData } from '../../../src/Interface'
 
 class MongoDBExisting_VectorStores extends MongoDBSearchBase implements INode {
     constructor() {
@@ -20,7 +19,7 @@ class MongoDBExisting_VectorStores extends MongoDBSearchBase implements INode {
         return super.init(nodeData, _, options, undefined)
     }
 
-    constructVectorStore(
+    async constructVectorStore(
         embeddings: Embeddings,
         collection: Collection,
         indexName: string,
@@ -28,13 +27,12 @@ class MongoDBExisting_VectorStores extends MongoDBSearchBase implements INode {
         embeddingKey: string,
         _: Document<Record<string, any>>[] | undefined
     ): Promise<VectorStore> {
-        const mongoDBAtlasVectorSearch = new MongoDBAtlasVectorSearch(embeddings, {
+        return new MongoDBAtlasVectorSearch(embeddings, {
             collection: collection,
             indexName: indexName,
             textKey: textKey,
             embeddingKey: embeddingKey
         })
-        return Promise.resolve(mongoDBAtlasVectorSearch)
     }
 }
 
diff --git a/packages/components/nodes/vectorstores/MongoDB/MongoDB_Upsert.ts b/packages/components/nodes/vectorstores/MongoDB/MongoDB_Upsert.ts
index 80dfbf19..7d22f035 100644
--- a/packages/components/nodes/vectorstores/MongoDB/MongoDB_Upsert.ts
+++ b/packages/components/nodes/vectorstores/MongoDB/MongoDB_Upsert.ts
@@ -1,12 +1,11 @@
-import { ICommonObject, INode, INodeData } from '../../../src/Interface'
+import { flatten } from 'lodash'
+import { Collection } from 'mongodb'
 import { Embeddings } from 'langchain/embeddings/base'
 import { Document } from 'langchain/document'
-
-import { flatten } from 'lodash'
 import { VectorStore } from 'langchain/vectorstores/base'
-import { MongoDBSearchBase } from './MongoDBSearchBase'
-import { Collection } from 'mongodb'
 import { MongoDBAtlasVectorSearch } from 'langchain/vectorstores/mongodb_atlas'
+import { ICommonObject, INode, INodeData } from '../../../src/Interface'
+import { MongoDBSearchBase } from './MongoDBSearchBase'
 
 class MongoDBUpsert_VectorStores extends MongoDBSearchBase implements INode {
     constructor() {
@@ -23,7 +22,7 @@ class MongoDBUpsert_VectorStores extends MongoDBSearchBase implements INode {
         })
     }
 
-    constructVectorStore(
+    async constructVectorStore(
         embeddings: Embeddings,
         collection: Collection,
         indexName: string,
@@ -31,12 +30,14 @@ class MongoDBUpsert_VectorStores extends MongoDBSearchBase implements INode {
         embeddingKey: string,
         docs: Document<Record<string, any>>[]
     ): Promise<VectorStore> {
-        return MongoDBAtlasVectorSearch.fromDocuments(docs, embeddings, {
+        const mongoDBAtlasVectorSearch = new MongoDBAtlasVectorSearch(embeddings, {
             collection: collection,
             indexName: indexName,
             textKey: textKey,
             embeddingKey: embeddingKey
         })
+        await mongoDBAtlasVectorSearch.addDocuments(docs)
+        return mongoDBAtlasVectorSearch
     }
 
     async init(nodeData: INodeData, _: string, options: ICommonObject): Promise<any> {
@@ -51,7 +52,7 @@ class MongoDBUpsert_VectorStores extends MongoDBSearchBase implements INode {
             }
         }
 
-        return super.init(nodeData, _, options, flattenDocs)
+        return super.init(nodeData, _, options, finalDocs)
     }
 }
 
diff --git a/packages/components/nodes/vectorstores/Redis/Redis_Upsert.ts b/packages/components/nodes/vectorstores/Redis/Redis_Upsert.ts
index 9d1a4f45..4da58eaf 100644
--- a/packages/components/nodes/vectorstores/Redis/Redis_Upsert.ts
+++ b/packages/components/nodes/vectorstores/Redis/Redis_Upsert.ts
@@ -56,7 +56,7 @@ class RedisUpsert_VectorStores extends RedisSearchBase implements INode {
             }
         }
 
-        return super.init(nodeData, _, options, flattenDocs)
+        return super.init(nodeData, _, options, finalDocs)
     }
 }