An actor allows remote control of a stateful object living on a remote worker. Method calls on this object trigger operations on the remote object and return ActorFutures on which we can block to get results.
>>> class Counter: ... def __init__(self): ... self.n = 0 ... def increment(self): ... self.n += 1 ... return self.n >>> from dask.distributed import Client >>> client = Client() You can create an actor by submitting a class with the keyword ``actor=True``. >>> future = client.submit(Counter, actor=True) >>> counter = future.result() >>> counter <Actor: Counter, key=Counter-1234abcd> Calling methods on this object immediately returns deferred ``ActorFuture`` objects. You can call ``.result()`` on these objects to block and get the result of the function call. >>> future = counter.increment() >>> future.result() 1 >>> future = counter.increment() >>> future.result() 2
This method overrides distributed.utils_comm.WrappedKey.__init__.