xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-03-29 05:33:33 +00:00
Code Issues Projects Releases Wiki Activity

Port enhancements from sync client to async

Browse Source
This commit is contained in:
Jarrod Johnson
2026-03-20 16:11:26 -04:00
parent 315fb0ced8
commit 7f80a4d5aa
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
confluent_client/confluent/asynclient.py
View File

@@ -80,7 +80,7 @@ def stringify(instr):
# Normalize unicode and bytes to 'str', correcting for
# current python version
if isinstance(instr, bytes) and not isinstance(instr, str):
return instr.decode('utf-8')
return instr.decode('utf-8', errors='replace')
elif not isinstance(instr, bytes) and not isinstance(instr, str):
return instr.encode('utf-8')
return instr
@@ -519,8 +519,8 @@ async def printattributes(session, requestargs, showtype, nodetype, noderange, o
def _sort_attrib(k):
if isinstance(k[1], dict) and k[1].get('sortid', None) is not None:
return k[1]['sortid']
return k[0]
return sortutil.naturalize_string('{}'.format(k[1]['sortid']))
return sortutil.naturalize_string(k[0])
async def print_attrib_path(path, session, requestargs, options, rename=None, attrprefix=None):
exitcode = 0