def continue_while_updates_pending(any_activity):
    return compat.any((current_connection.writable() for current_connection in connection_set))
def continue_while_updates_pending(any_activity):
    return compat.any((current_connection.writable() for current_connection in connection_set))