

def _heartbeat_stopped(self, connection):
    for (correlation_id, invocation) in dict(self._pending).iteritems():
        if (invocation.sent_connection == connection):
            correlation_id._handle_exception(invocation, TargetDisconnectedError(('%s has stopped heart beating.' % connection)))

dataset/ETHPy150Open hazelcast/hazelcast-python-client/hazelcast/invocation.py InvocationService._heartbeat_stopped/VarMisuse@43/55 `self`->`correlation_id`