Actors on same worker cause deadlock #4224
Description
Consider
client = dask.distributed.Client()
class Minimal:
def thetime(self):
import time
return time.time()
class UsesMinimal():
def getthetime(self, ac):
return ac.thetime().result()The following works
ac = client.submit(Minimal, actor=True, workers=["127.0.0.1:61047"]).result()
ac2 = client.submit(UsesMinimal, actor=True, workers=['tcp://127.0.0.1:61046']).result()
ac2.getthetime(ac).result()but if they are on the same worker
ac2 = client.submit(UsesMinimal, actor=True, workers=['tcp://127.0.0.1:61047']).result()
ac2.getthetime(ac).result()... deadlock
- Dask version: master (dask/distributed)
- Python version: 3.7
- Operating System: osx
- Install method (conda, pip, source): source