Fix for Kafka plugin on CI
Change-Id: Id053c5f8e3038ebe8692b1306ac794d0cd663d44
This commit is contained in:
parent
ddbdfec778
commit
b0d0ba18f8
@ -52,9 +52,8 @@ class KafkaPluginApi(base_test.PluginApi):
|
||||
logger.info("Check that {} (port {}) on node {} (IP: {}) is up"
|
||||
.format(port['name'], port['number'],
|
||||
node['name'], node['ip']))
|
||||
msg = "Port {} ({}) is {} on node {}".format(port['name'],
|
||||
port['number'],
|
||||
node['name'])
|
||||
msg = "Port {} ({}) is unreachable on node {}".format(
|
||||
port['name'], port['number'], node['name'])
|
||||
asserts.assert_true(result, msg)
|
||||
|
||||
def uninstall_plugin(self):
|
||||
|
Loading…
Reference in New Issue
Block a user