async def METHOD_NAME():
    stq = SampleTablesQuery()
    try:
        await stq.insert_random_entities()
        await stq.sample_query_entities()
    except Exception as e:
        print(e)
    finally:
        await stq.clean_up()