openstack/deb-python-kafka
Code Issues Proposed changes

Fallback to simple repr() in Schema.repr()

Browse Source
This commit is contained in:
Dana Powers
2015-12-09 15:14:50 -08:00
parent c4f87bce20
commit 5aeba4a7dc
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
kafka/protocol/types.py
View File

@@ -105,13 +105,16 @@ class Schema(AbstractType):
def repr(self, value):
key_vals = []
for i in range(len(self)):
try:
field_val = getattr(value, self.names[i])
except AttributeError:
field_val = value[i]
key_vals.append('%s=%s' % (self.names[i], self.fields[i].repr(field_val)))
return '(' + ', '.join(key_vals) + ')'
try:
for i in range(len(self)):
try:
field_val = getattr(value, self.names[i])
except AttributeError:
field_val = value[i]
key_vals.append('%s=%s' % (self.names[i], self.fields[i].repr(field_val)))
return '(' + ', '.join(key_vals) + ')'
except:
return repr(value)
class Array(AbstractType):