summaryrefslogtreecommitdiff
path: root/kafka/util.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2017-08-30 15:09:25 -0700
committerJeff Widman <jeff@jeffwidman.com>2020-02-05 15:57:01 -0800
commit6babefab60b05e405fdebde89e27fd8b02848633 (patch)
treed09fb906fabd104e456418a1c3045438af926e97 /kafka/util.py
parent66f9750e0fc5617ebc38a76144aa49d94b442f35 (diff)
downloadkafka-python-6babefab60b05e405fdebde89e27fd8b02848633.tar.gz
Remove some dead code
Diffstat (limited to 'kafka/util.py')
-rw-r--r--kafka/util.py9
1 files changed, 0 insertions, 9 deletions
diff --git a/kafka/util.py b/kafka/util.py
index 9f65b81..ca1e531 100644
--- a/kafka/util.py
+++ b/kafka/util.py
@@ -65,12 +65,3 @@ class Dict(dict):
See: https://docs.python.org/2/library/weakref.html
"""
pass
-
-
-def try_method_on_system_exit(obj, method, *args, **kwargs):
- def wrapper(_obj, _meth, *args, **kwargs):
- try:
- getattr(_obj, _meth)(*args, **kwargs)
- except (ReferenceError, AttributeError):
- pass
- atexit.register(wrapper, weakref.proxy(obj), method, *args, **kwargs)