From 347c7fdc1e7daac3233fc939fd53b9e19c72ae72 Mon Sep 17 00:00:00 2001
From: Jarrod Johnson <jjohnson2@lenovo.com>
Date: Tue, 28 Apr 2026 16:08:24 -0400
Subject: [PATCH] Fix osdeploy list

---
 confluent_server/bin/osdeploy | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/confluent_server/bin/osdeploy b/confluent_server/bin/osdeploy
index 670d0fee..c0c99906 100644
--- a/confluent_server/bin/osdeploy
+++ b/confluent_server/bin/osdeploy
@@ -64,11 +64,11 @@ async def main(args):
     cmdset = ap.parse_args()
 
     if cmdset.command == 'list':
-        return oslist()
+        return await oslist()
     if cmdset.command == 'import':
         return await osimport(cmdset.imagefile, custname=cmdset.n)
     if cmdset.command == 'importcheck':
-        return osimport(cmdset.imagefile, checkonly=True)
+        return await osimport(cmdset.imagefile, checkonly=True)
     if cmdset.command == 'initialize':
         return await initialize(cmdset)
     if cmdset.command == 'updateboot':
@@ -511,10 +511,10 @@ async def rebase(profilename):
         else:
             print(repr(rsp))
 
-def oslist():
+async def oslist():
     c = client.Command()
     print("Distributions:")
-    for rsp in c.read('/deployment/distributions'):
+    async for rsp in c.read('/deployment/distributions'):
         if 'error' in rsp:
             sys.stderr.write(rsp['error'] + '\n')
             exitcode = 1
@@ -523,7 +523,7 @@ def oslist():
     print("")
 
     print("Profiles:")
-    for rsp in c.read('/deployment/profiles'):
+    async for rsp in c.read('/deployment/profiles'):
         if 'error' in rsp:
             sys.stderr.write(rsp['error'] + '\n')
             exitcode = 1