import asyncio

import distributed


class Actor:
    def action(self):
        return "acted"


async def amain():
    async with distributed.Client(
        processes=True, security=True, asynchronous=True
    ) as client:
        actor = await client.submit(Actor, actor=True)
        inc_fut = actor.action()

        async def wait(v):
            return await v

        assert await asyncio.gather(wait(inc_fut), wait(inc_fut)) == ["acted", "acted"]


if __name__ == "__main__":
    asyncio.run(amain())