summaryrefslogtreecommitdiff
path: root/kafka/producer
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-02-18 21:53:11 -0800
committerDana Powers <dana.powers@gmail.com>2016-02-18 21:53:11 -0800
commit2dd216b5acafb89d177a79ec779374c5a6f94dcf (patch)
treedb29a87205eb8be15a2798ae681ff47f12c34289 /kafka/producer
parent799f53f71275aec7a32c2935837f7c8f3d6283c0 (diff)
downloadkafka-python-2dd216b5acafb89d177a79ec779374c5a6f94dcf.tar.gz
Some attributes may not exist in __del__ if we failed assertions
Diffstat (limited to 'kafka/producer')
-rw-r--r--kafka/producer/kafka.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer/kafka.py b/kafka/producer/kafka.py
index 11eeddd..37cd9b6 100644
--- a/kafka/producer/kafka.py
+++ b/kafka/producer/kafka.py
@@ -270,7 +270,7 @@ class KafkaProducer(object):
def close(self, timeout=None):
"""Close this producer."""
- if self._closed:
+ if not hasattr(self, '_closed') or self._closed:
log.info('Kafka producer closed')
return
if timeout is None: