From f4c68032e3d1aec7f1ca28099cc0c6aafe3b2914 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Wed, 15 Apr 2026 10:03:57 -0400 Subject: [PATCH] Change noderemove to use sync client for now --- confluent_client/bin/noderemove | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/confluent_client/bin/noderemove b/confluent_client/bin/noderemove index 5a912fcf..4b2659eb 100755 --- a/confluent_client/bin/noderemove +++ b/confluent_client/bin/noderemove @@ -1,4 +1,4 @@ -#!/usr/bin/python2 +#!/usr/bin/python3 # vim: tabstop=4 shiftwidth=4 softtabstop=4 # Copyright 2017 Lenovo @@ -50,8 +50,8 @@ async def main(): client.check_globbing(noderange) session = client.Command() exitcode = 0 - await session.stop_if_noderange_over(noderange, options.maxnodes) - async for r in session.delete('/noderange/{0}'.format(noderange)): + session.stop_if_noderange_over(noderange, options.maxnodes) + for r in session.delete('/noderange/{0}'.format(noderange)): if 'error' in r: sys.stderr.write(r['error'] + '\n') exitcode |= 1 @@ -61,4 +61,4 @@ async def main(): if __name__ == '__main__': - asyncio.get_event_loop().run_until_complete(main()) + asyncio.run(main())