From bda31503c27271d234aee969d07ba9711f991d55 Mon Sep 17 00:00:00 2001 From: Danil D Date: Fri, 17 Nov 2023 12:14:41 +0300 Subject: [PATCH] fix typo (cherry picked from commit 2e08005d9802afe0424ce3805b537cc2c597a4f7) --- smart_kit/start_points/main_loop_kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/smart_kit/start_points/main_loop_kafka.py b/smart_kit/start_points/main_loop_kafka.py index 8ad3fd7d..a5907376 100644 --- a/smart_kit/start_points/main_loop_kafka.py +++ b/smart_kit/start_points/main_loop_kafka.py @@ -76,7 +76,7 @@ def __init__(self, *args, **kwargs): self.worker_tasks = [] self.max_concurrent_messages = self.template_settings.get("max_concurrent_messages", 10) if self.max_concurrent_messages < 1: - raise ValueError(f"max_concurrent_messages must be greater than 0 (actual: {self.max_concurrent_messages}") + raise ValueError(f"max_concurrent_messages must be greater than 0 (actual: {self.max_concurrent_messages})") self.queues = [asyncio.Queue() for _ in range(self.max_concurrent_messages)] self.total_messages = 0