weakref.ref does not support keyword args in python 2.7.12+

aholmberg · aholmberg · commit 1afa1f4b2f29 · 2016-05-23T09:16:07.000-05:00
With thanks to Jan Urbański in apache#585 for the heads up.
diff --git a/cassandra/cluster.py b/cassandra/cluster.py
@@ -2262,7 +2262,7 @@ def _try_connect(self, host):
         # _clear_watcher will be called when this ControlConnection is about to be finalized
         # _watch_callback will get the actual callback from the Connection and relay it to
         # this object (after a dereferencing a weakref)
-        self_weakref = weakref.ref(self, callback=partial(_clear_watcher, weakref.proxy(connection)))
+        self_weakref = weakref.ref(self, partial(_clear_watcher, weakref.proxy(connection)))
         try:
             connection.register_watchers({
                 "TOPOLOGY_CHANGE": partial(_watch_callback, self_weakref, '_handle_topology_change'),
