Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
(cherry picked from commit 2e08005)
  • Loading branch information
Dan1lD committed Dec 1, 2023
1 parent dbd50c6 commit bda3150
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion smart_kit/start_points/main_loop_kafka.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down

0 comments on commit bda3150

Please sign in to comment.