Merge branch 'dev' into feature/cog-3160-redis-session-conversation

2025-10-20 15:21:56 +02:00 · 2025-10-20 15:21:56 +02:00 · dd8afe42f8
commit dd8afe42f8
parent d2d2cfb477 3e54b67b4d
1 changed files with 1 additions and 0 deletions
--- a/cognee/modules/pipelines/operations/run_tasks_distributed.py
+++ b/cognee/modules/pipelines/operations/run_tasks_distributed.py
@ -88,6 +88,7 @@ async def run_tasks_distributed(
    pipeline_name: str = "unknown_pipeline",
    context: dict = None,
    incremental_loading: bool = False,
+    data_per_batch: int = 20,
 ):
    if not user:
        user = await get_default_user()