From 022439e01711ca3c7b5c7e721dfe8017191e4922 Mon Sep 17 00:00:00 2001
From: Mikhail Epifanov <mikhail.epifanov@gmail.com>
Date: Fri, 12 Jan 2024 23:40:16 +0100
Subject: [PATCH] increase queue size to account for recipe adding burst

---
 cookbook/connectors/connector_manager.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/cookbook/connectors/connector_manager.py b/cookbook/connectors/connector_manager.py
index d660b6d8..332f2f0d 100644
--- a/cookbook/connectors/connector_manager.py
+++ b/cookbook/connectors/connector_manager.py
@@ -17,7 +17,7 @@ from cookbook.models import ShoppingListEntry, Recipe, MealPlan, Space
 
 multiprocessing.set_start_method('fork')  # https://code.djangoproject.com/ticket/31169
 
-QUEUE_MAX_SIZE = 10
+QUEUE_MAX_SIZE = 25
 REGISTERED_CLASSES: UnionType = ShoppingListEntry | Recipe | MealPlan | Connector
 
 
@@ -116,6 +116,9 @@ async def run_connectors(connectors: List[Connector], space: Space, instance: RE
                 for connector in connectors:
                     tasks.append(asyncio.create_task(connector.on_shopping_list_entry_deleted(space, shopping_list_entry)))
 
+    if len(tasks) == 0:
+        return
+
     try:
         await asyncio.gather(*tasks, return_exceptions=False)
     except BaseException: