def ensured(self, connection, obj, to_ensure_func, **kwargs):
        ensuring_func = connection.ensure(obj, to_ensure_func, errback=self.errback, max_retries=3)
        ensuring_func(**kwargs)
Ensure that recoverable errors are retried a set number of times before giving up.
dataset/ETHPy150Open StackStorm/st2/st2common/st2common/transport/connection_retry_wrapper.py/ConnectionRetryWrapper.ensured