xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-22 09:32:21 +00:00
Code Issues Projects Releases Wiki Activity

Fix nodeshell/nodersync python3 changes

Browse Source
This commit is contained in:
Jarrod Johnson 2019-10-14 09:37:30 -04:00
parent 8c4d04a7cd
commit bed0f76dba
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
confluent_client/bin/nodersync
View File

@ -100,7 +100,7 @@ def run():
if desc['type'] == 'stdout':
if node not in pernodeout:
pernodeout[node] = ''
pernodeout[node] += data
pernodeout[node] += stringify(data)
if '\n' in pernodeout[node]:
currout, pernodeout[node] = pernodeout[node].split('\n', 1)
if currout:

2
confluent_client/bin/nodeshell
View File

@ -73,7 +73,7 @@ def run():
ex = exp.get('databynode', ())
for node in ex:
cmd = ex[node]['value']
if not isinstance(str) and not isinstance(bytes):
if not isinstance(cmd, str) and not isinstance(cmd, bytes):
cmd = cmd.encode('utf-8')
cmdv = ['ssh', node, cmd]
if currprocs < concurrentprocs: