Skip to content

Commit 73b2491

Browse files
committed
Add a bunch of TODOs
1 parent ce6c65f commit 73b2491

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

kafka/producer/buffer.py

+1
Original file line numberDiff line numberDiff line change
@@ -114,6 +114,7 @@ def queued(self):
114114
with self._lock:
115115
return len(self._waiters)
116116

117+
# TODO should this be removed or finished?
117118
'''
118119
class BufferPool(object):
119120
"""

kafka/protocol/struct.py

+1
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@ def __eq__(self, other):
6565
return False
6666
return True
6767

68+
# TODO should this be removed or finished?
6869
"""
6970
class MetaStruct(type):
7071
def __new__(cls, clsname, bases, dct):

kafka/util.py

+1
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ class Dict(dict):
6767
pass
6868

6969

70+
# TODO what is the purpose of this? It has been unused since it was originally added
7071
def try_method_on_system_exit(obj, method, *args, **kwargs):
7172
def wrapper(_obj, _meth, *args, **kwargs):
7273
try:

0 commit comments

Comments
 (0)