openstack/deb-python-kafka
Code Issues Proposed changes

Add failed_payloads attribute to FailedPayloadsError

Browse Source
This commit is contained in:
Job Evers
2015-01-22 17:25:02 -06:00
committed by Dana Powers
parent e6b37c00c5
commit 95737d9b89
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/common.py
View File

@@ -161,7 +161,9 @@ class KafkaTimeoutError(KafkaError):
class FailedPayloadsError(KafkaError):
pass
def __init__(self, failed_payloads, *args):
super(FailedPayloadsError, self).__init__(*args)
self.failed_payloads = failed_payloads
class ConnectionError(KafkaError):