kafka: fix python3 exception
Change-Id: I7244515f274719eb8e9189677554637e20917274
This commit is contained in:
parent
61c9e03b6b
commit
c7cdf2d9b7
@ -191,7 +191,7 @@ class Connection(object):
|
|||||||
"""
|
"""
|
||||||
|
|
||||||
def _raise_timeout(exc):
|
def _raise_timeout(exc):
|
||||||
raise driver_common.Timeout(exc.message)
|
raise driver_common.Timeout(str(exc))
|
||||||
|
|
||||||
timer = driver_common.DecayingTimer(duration=timeout)
|
timer = driver_common.DecayingTimer(duration=timeout)
|
||||||
timer.start()
|
timer.start()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user