diff options
author | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:14:50 -0800 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:14:50 -0800 |
commit | 5aeba4a7dc68e76c96f743a8a9e3e6603875695e (patch) | |
tree | 42e916e7dfbd62990406f40782bb12bf87a5232e /kafka/protocol | |
parent | c4f87bce204d27cb7897baccab8454f997ce6c49 (diff) | |
download | kafka-python-5aeba4a7dc68e76c96f743a8a9e3e6603875695e.tar.gz |
Fallback to simple repr() in Schema.repr()
Diffstat (limited to 'kafka/protocol')
-rw-r--r-- | kafka/protocol/types.py | 17 |
1 files changed, 10 insertions, 7 deletions
diff --git a/kafka/protocol/types.py b/kafka/protocol/types.py index 99d89a6..01799bb 100644 --- a/kafka/protocol/types.py +++ b/kafka/protocol/types.py @@ -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): |