cgiacofei/TandoorRecipes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

increase queue size to account for recipe adding burst

Browse Source
This commit is contained in:
Mikhail Epifanov 2024-01-12 23:40:16 +01:00
parent 9c804863a8
commit 022439e017
No known key found for this signature in database
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cookbook/connectors/connector_manager.py
View File

@ -17,7 +17,7 @@ from cookbook.models import ShoppingListEntry, Recipe, MealPlan, Space
multiprocessing.set_start_method('fork') # https://code.djangoproject.com/ticket/31169 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 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: for connector in connectors:
tasks.append(asyncio.create_task(connector.on_shopping_list_entry_deleted(space, shopping_list_entry))) tasks.append(asyncio.create_task(connector.on_shopping_list_entry_deleted(space, shopping_list_entry)))
if len(tasks) == 0:
return
try: try:
await asyncio.gather(*tasks, return_exceptions=False) await asyncio.gather(*tasks, return_exceptions=False)
except BaseException: except BaseException: