We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 22488c5 commit 4b98b38Copy full SHA for 4b98b38
snafu/log_generator_wrapper/trigger_log_generator.py
@@ -284,7 +284,7 @@ def emit_actions(self):
284
elif self.kafka_bootstrap_server:
285
messages_received = self._check_kafka(start_time, end_time + self.timeout)
286
if messages_received >= message_count-10: # ES misses 1 or 2 messages inconsistently and very negligible, so tolerating 0.00001% loss.
287
- received_all_messages = True
+ received_all_messages = True
288
else:
289
logger.info("Message check failed. Received %d messages of %d. Retrying until timeout" % (messages_received, message_count))
290
if self.kafka_bootstrap_server:
0 commit comments