fix non_tensor_fields bug in parallel calls

LLYX · Nov 9, 2022 · 2b0091f · 2b0091f
1 parent 129fc52
commit 2b0091f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/marqo/tensor_search/parallel.py b/src/marqo/tensor_search/parallel.py
@@ -203,7 +203,7 @@ def add_documents_mp(config=None, index_name=None, docs=None,
     start = time.time()
 
     chunkers = [IndexChunk(
-            config=config, index_name=index_name, docs=_docs,
+            config=config, index_name=index_name, docs=_docs, non_tensor_fields=non_tensor_fields,
             auto_refresh=auto_refresh, batch_size=batch_size, update_mode=update_mode,
             process_id=p_id, device=device_ids[p_id], threads_per_process=threads_per_process)
         for p_id,_docs in enumerate(np.array_split(docs, n_processes))]