2
0
mirror of https://github.com/xcat2/confluent.git synced 2026-04-06 00:46:27 +00:00

Fix syntax mistake in deferred handling in nodeapply

This commit is contained in:
Jarrod Johnson
2026-04-03 10:34:20 -04:00
parent a123165712
commit 69d984b9dc

View File

@@ -183,7 +183,7 @@ def run():
run_cmdv(node, cmdv, all, poller, pipedesc)
elif pendingexecs:
node, cmdv = pendingexecs.popleft()
run_cmdv(node, cmdv, all, poller. pipedesc)
run_cmdv(node, cmdv, all, poller, pipedesc)
singlepoller.close()
for node in sortutil.natural_sort(pernodeout):
for line in pernodeout[node]: