From 91aed84e1d18817cee0d0fa8a9df261985144e8e Mon Sep 17 00:00:00 2001 From: Anthony Mahanna Date: Mon, 26 Feb 2024 21:26:22 -0500 Subject: [PATCH] attempt: insert_many instead of import_bulk --- adbpyg_adapter/adapter.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adbpyg_adapter/adapter.py b/adbpyg_adapter/adapter.py index 7b3cc36..cb25b9d 100644 --- a/adbpyg_adapter/adapter.py +++ b/adbpyg_adapter/adapter.py @@ -1819,7 +1819,7 @@ def __insert_adb_docs( docs = df.to_dict("records") db = self.__async_db if use_async else self.__db - result = db.collection(col).import_bulk(docs, **adb_import_kwargs) + result = db.collection(col).insert_many(docs, **adb_import_kwargs) logger.debug(result) df.drop(df.index, inplace=True)