From c5cba30997d7dfe7f783b3ab80f7062c5c7af0ad Mon Sep 17 00:00:00 2001 From: estromenko Date: Mon, 3 Nov 2025 15:52:27 +0300 Subject: [PATCH] Increase batch size for vacancies collecting task --- .../commands/collect_vacancies_from_telegram_messages.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/vacancies/main/management/commands/collect_vacancies_from_telegram_messages.py b/vacancies/main/management/commands/collect_vacancies_from_telegram_messages.py index a360c6e..07f6fed 100644 --- a/vacancies/main/management/commands/collect_vacancies_from_telegram_messages.py +++ b/vacancies/main/management/commands/collect_vacancies_from_telegram_messages.py @@ -49,7 +49,7 @@ class Command(BaseCommand): exist_points_set = tuple(set(exist_points_ids)) result_rows = clickhouse_client.query(query, parameters={"exist_points": exist_points_set}).result_rows - batch_size = 10 + batch_size = 30 with ThreadPoolExecutor(max_workers=batch_size) as pool: pool.map(self._process_batch, batched(result_rows, batch_size))