def _schema_update(self, schema_func, *args):
        while True:
            try:
                schema_version = schema_func(*args)
            except SchemaDisagreementException:
                self._wait_for_agreement()
            else:
                break
        return schema_version
Call schema updates functions and properly
dataset/ETHPy150Open pycassa/pycassa/pycassa/system_manager.py/SystemManager._schema_update