Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Dan1lD committed Nov 17, 2023
1 parent 3f77e1b commit 2e08005
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 @@ -79,7 +79,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 2e08005

Please sign in to comment.