@app.listener('before_server_start')
async def setup(context, loop):
    context.executor = ThreadPoolExecutor()
    context.pool = (await repeated_pool(loop, 5, 10))
    (await retrain(context, loop))
@app.listener('before_server_start')
async def setup(context, loop):
    context.executor = ThreadPoolExecutor()
    context.pool = (await repeated_pool(loop, 5, 10))
    (await retrain(context, loop))