openstack/deb-python-kafka
Code Issues Proposed changes

Merge branch 'jobevers-master'

Browse Source 
PR 302: Add failed_payloads attribute to FailedPayloadsError
This commit is contained in:
Dana Powers
2015-03-08 15:16:17 -07:00
parent 327b734940 95737d9b89
commit 6ef982c5e8
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): class FailedPayloadsError(KafkaError):
pass def __init__(self, failed_payloads, *args):
super(FailedPayloadsError, self).__init__(*args)
self.failed_payloads = failed_payloads
class ConnectionError(KafkaError): class ConnectionError(KafkaError):