diff --git a/medcat_service/nlp_processor/medcat_processor.py b/medcat_service/nlp_processor/medcat_processor.py
index 216c25e..4ba772f 100644
--- a/medcat_service/nlp_processor/medcat_processor.py
+++ b/medcat_service/nlp_processor/medcat_processor.py
@@ -186,8 +186,8 @@ def process_content_bulk(self, content):
             if eval(self.DEID_MODE):
                 ann_res = self.cat.deid_text()
             else:
-                ann_res = self.cat.multiprocessing(
-                    MedCatProcessor._generate_input_doc(content, invalid_doc_ids), nproc=nproc)
+                ann_res = self.cat.multiprocessing_batch_docs_size(
+                    MedCatProcessor._generate_input_doc(content, invalid_doc_ids), batch_size = batch_size, nproc=nproc)
 
         except Exception as e:
             self.log.error(repr(e))