2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-03-22 10:09:17 +00:00

Fix issues in nodeconfig async

This commit is contained in:
Jarrod Johnson
2026-03-03 12:42:29 -05:00
parent 9abe1f98b7
commit 27a3a446fe

View File

@@ -31,7 +31,7 @@ path = os.path.realpath(os.path.join(path, '..', 'lib', 'python'))
if path.startswith('/opt'):
sys.path.append(path)
import confluent.client as client
import confluent.asynclient as client
class NullOpt(object):
blame = None
@@ -223,6 +223,7 @@ def parse_config_line(arguments, single=False):
queryparms[path][attrib] = param
async def main():
printsys = []
if options.batch:
printsys = []
argfile = open(options.batch, 'r')