Skip to content

Commit

Permalink
removed extra chars
Browse files Browse the repository at this point in the history
  • Loading branch information
mukrishn authored and Russell Zaleski committed Mar 31, 2023
1 parent 22488c5 commit 4b98b38
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion snafu/log_generator_wrapper/trigger_log_generator.py
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,7 @@ def emit_actions(self):
elif self.kafka_bootstrap_server:
messages_received = self._check_kafka(start_time, end_time + self.timeout)
if messages_received >= message_count-10: # ES misses 1 or 2 messages inconsistently and very negligible, so tolerating 0.00001% loss.
received_all_messages = True
received_all_messages = True
else:
logger.info("Message check failed. Received %d messages of %d. Retrying until timeout" % (messages_received, message_count))
if self.kafka_bootstrap_server:
Expand Down

0 comments on commit 4b98b38

Please sign in to comment.