Chris O'Brien
01/22/2020, 1:55 AMdistributed.core - INFO - Starting established connection
distributed.core - ERROR - add_client() got an unexpected keyword argument 'versions'
Traceback (most recent call last):
File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/distributed/core.py", line 412, in handle_comm
result = handler(comm, **msg)
TypeError: add_client() got an unexpected keyword argument 'versions'
With dask-scheduler, version 2.2.0
and Prefect, version 0.9.0
. Makes me think a version issue?Chris White
01/22/2020, 2:01 AMjosh
01/22/2020, 2:01 AMdistributed
version in the prefecthq/prefect docker image is 2.9.1
but the version of distributed that your flow is using is probably higher. Are you building your flow with a Docker storage?Chris O'Brien
01/22/2020, 2:05 AM"dask": {
...
"version": "==2.9.2"
},
Thinking I should downgrade this?Chris White
01/22/2020, 2:09 AM2.9.0
and it should begin working; you could also build your own custom image to use within the cluster if you use any 2.9.2-specific featuresChris O'Brien
01/22/2020, 2:52 AMdistributed.client - WARNING - Couldn't gather 37 keys, rescheduling
Chris White
01/22/2020, 3:21 AMChris O'Brien
01/22/2020, 5:00 AMChris White
01/22/2020, 5:02 AMjosh
01/27/2020, 10:13 PMMarvin
01/27/2020, 10:13 PM