root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: fix expected version in streams upgrade test (#13022) 

Co-authored-by: Lucas Brutschy <lucasbru@users.noreply.github.com>

Reviewers: Suhas Satish <ssatish@confluent.io>, Lucas Brutschy <lbrutschy@confluent.io>,  John Roesler <john@confluent.io>
This commit is contained in:
Matthias J. Sax 2022-12-27 10:09:27 -08:00 committed by GitHub
parent cc586ea0c9
commit 9e71f9cc7d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/kafkatest/tests/streams/streams_upgrade_test.py
View File

@ -511,6 +511,8 @@ class StreamsUpgradeTest(Test):
first_other_node = first_other_processor.node first_other_node = first_other_processor.node
second_other_node = second_other_processor.node second_other_node = second_other_processor.node
kafka_version_str = self.get_version_string(str(DEV_VERSION))
with first_other_node.account.monitor_log(first_other_processor.LOG_FILE) as first_other_monitor: with first_other_node.account.monitor_log(first_other_processor.LOG_FILE) as first_other_monitor:
with second_other_node.account.monitor_log(second_other_processor.LOG_FILE) as second_other_monitor: with second_other_node.account.monitor_log(second_other_processor.LOG_FILE) as second_other_monitor:
# stop processor # stop processor
@ -528,7 +530,7 @@ class StreamsUpgradeTest(Test):
self.upgraded_processors.append(processor) self.upgraded_processors.append(processor)
# checking for the dev version which should be the only SNAPSHOT # checking for the dev version which should be the only SNAPSHOT
log_monitor.wait_until("Kafka version.*" + self.base_version_number + ".*SNAPSHOT", log_monitor.wait_until(kafka_version_str,
timeout_sec=60, timeout_sec=60,
err_msg="Could not detect Kafka Streams version " + str(DEV_VERSION) + " in " + str(node.account)) err_msg="Could not detect Kafka Streams version " + str(DEV_VERSION) + " in " + str(node.account))
log_monitor.offset = 5 log_monitor.offset = 5