Asyncio botocore waiter

botocore_waiter_asyncio.py

import asyncio
import botocore.session
import functools

cloudformation_template = """
{
  "AWSTemplateFormatVersion": "2010-09-09",
  "Resources": {
    "queue1": {
      "Type": "AWS::SQS::Queue",
      "Properties": {
        "QueueName": "my-queue"
      }
    }
  }
}
"""

loop = asyncio.get_event_loop()
session = botocore.session.get_session()
cloudformation_client = session.create_client('cloudformation', region_name='us-east-1')


async def create_stack():
    print('creating cloudformation stack')
    await loop.run_in_executor(
        None,
        functools.partial(
            cloudformation_client.create_stack, StackName='my-stack', TemplateBody=cloudformation_template))


async def wait_for_stack_create_complete():
    print('waiting for cloudformation stack creation to complete')
    waiter = cloudformation_client.get_waiter('stack_create_complete')
    await loop.run_in_executor(None, functools.partial(waiter.wait, StackName='my-stack'))


loop.run_until_complete(create_stack())
loop.run_until_complete(wait_for_stack_create_complete())