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))