Tsang Yong
10/10/2020, 4:20 AMERROR - prefect.FlowRunner | Unexpected error: TypeError('code() takes at most 15 arguments (16 given)')
not sure if it’s a supported mode of operation.Chris White
Tsang Yong
10/10/2020, 4:30 AMdask.config.set({'kubernetes.worker_template_path': 'my-prefect-dask-worker.yml'})
dask_executor = DaskExecutor(
cluster_class=KubeCluster,
cluster_kwargs={
'name': 'dask-worker-{JUPYTERHUB_USER}-{uuid}',
'n_workers': 3
},
)
flow.run(executor=dask_executor)
Traceback (most recent call last):
File "/opt/conda/lib/python3.8/site-packages/prefect/engine/runner.py", line 48, in inner
new_state = method(self, state, *args, **kwargs)
File "/opt/conda/lib/python3.8/site-packages/prefect/engine/flow_runner.py", line 600, in get_flow_run_state
final_states = executor.wait(
File "/opt/conda/lib/python3.8/site-packages/prefect/engine/executors/dask.py", line 451, in wait
return self.client.gather(futures)
File "/opt/conda/lib/python3.8/site-packages/distributed/client.py", line 1987, in gather
return self.sync(
File "/opt/conda/lib/python3.8/site-packages/distributed/client.py", line 833, in sync
return sync(
File "/opt/conda/lib/python3.8/site-packages/distributed/utils.py", line 339, in sync
raise exc.with_traceback(tb)
File "/opt/conda/lib/python3.8/site-packages/distributed/utils.py", line 323, in f
result[0] = yield future
File "/opt/conda/lib/python3.8/site-packages/tornado/gen.py", line 735, in run
value = future.result()
File "/opt/conda/lib/python3.8/site-packages/distributed/client.py", line 1852, in _gather
raise exception.with_traceback(traceback)
File "/usr/local/lib/python3.7/site-packages/distributed/protocol/pickle.py", line 75, in loads
TypeError: code() takes at most 15 arguments (16 given)
perhaps I have a bad version?
distributed==2.28.0
prefect==0.13.4
Chris White
Tsang Yong
10/10/2020, 4:39 AMcloudpickle==1.6.0
Jim Crist-Harif
10/10/2020, 1:45 PMTsang Yong
10/10/2020, 4:55 PM