async def repeated_pool(loop, sleeper, tries):
    n = 1
    while (n <= tries):
        try:
            return (await create_pool(**read_mysql_config()._asdict(), autocommit=True, loop=loop, pool_recycle=600))
        except OperationalError as e:
            getLogger('root').warn(e)
            getLogger('root').warn('Waiting {}s before retry'.format(sleeper))
            (await sleep(sleeper))
            n += 1
    return (await create_pool(**read_mysql_config()._asdict(), autocommit=True, loop=loop, pool_recycle=600))
async def repeated_pool(loop, sleeper, tries):
    n = 1
    while (n <= tries):
        try:
            return (await create_pool(**read_mysql_config()._asdict(), autocommit=True, loop=loop, pool_recycle=600))
        except OperationalError as e:
            getLogger('root').warn(e)
            getLogger('root').warn('Waiting {}s before retry'.format(sleeper))
            (await sleep(sleeper))
            n += 1
    return (await create_pool(**read_mysql_config()._asdict(), autocommit=True, loop=loop, pool_recycle=600))