async def METHOD_NAME(orders: StreamT[Order]) -> None:
    async for order in orders:
        execution_id = uuid()
        if not order.fake:
            # bla bla bla
            pass
        await test_order.order_executed.send(execution_id)
        print("5. ORDER EXECUTED BY EXECUTION AGENT")