From 50da83b4f57d0300c11863d4a74cb4eaa035ca9b Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Thu, 24 Feb 2022 15:56:29 -0500 Subject: [PATCH] Fix api token message not being pushed --- .../common/initramfs/opt/confluent/bin/apiclient | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/confluent_osdeploy/common/initramfs/opt/confluent/bin/apiclient b/confluent_osdeploy/common/initramfs/opt/confluent/bin/apiclient index f808ff0b..a22f9efd 100644 --- a/confluent_osdeploy/common/initramfs/opt/confluent/bin/apiclient +++ b/confluent_osdeploy/common/initramfs/opt/confluent/bin/apiclient @@ -266,7 +266,7 @@ class HTTPSClient(client.HTTPConnection, object): for line in info: if line.startswith('deploy_server: ') or line.startswith('deploy_server_v6: '): self.hosts.append(line.split(': ', 1)[1]) - self.stdheaders['CONFLUENT_APIKEY'] = get_apikey(node, self.hosts) + self.stdheaders['CONFLUENT_APIKEY'] = get_apikey(node, self.hosts, errout=self.errout) if mgtiface: self.stdheaders['CONFLUENT_MGTIFACE'] = mgtiface self.port = port @@ -368,7 +368,7 @@ class HTTPSClient(client.HTTPConnection, object): with open('/etc/confluent/confluent.apikey', 'w+') as akfile: akfile.write('') self.stdheaders['CONFLUENT_APIKEY'] = get_apikey( - self.node, [self.host]) + self.node, [self.host], errout=self.errout) raise Exception(rsp.read()) if __name__ == '__main__':