async def METHOD_NAME(loop):
    stresser = Stresser(num_workers=4, num_producers=4, loop=loop)
    checker = ConsistencyChecker(
        "withdrawals", "f-simple-user_to_total-changelog", loop=loop
    )
    print("Starting stresser")
    await stresser.start(stopped_at_start=1)
    print("Waiting for stresser to run")
    await asyncio.sleep(180)  # seconds to run stresser for
    print("Stopping all producers")
    await stresser.stop_all_producers()
    await checker.build_source()
    print("Waiting to stop stresser")
    await asyncio.sleep(5.0)
    stresser.stop_stresser()
    await checker.wait_no_lag()
    print("Stopping everything")
    await stresser.stop_all()
    await checker.build_changelog()
    await checker.check_consistency()