question on dask-kubernetes, I get a ERROR - prefect.FlowRunner | Unexpected error: ValueError(“Unexpected keyword arguments: [‘processes’, ‘silence_logs’]“,)
Traceback (most recent call last):
File “/usr/local/lib/python3.6/dist-packages/prefect/engine/runner.py”, line 48, in inner
new_state = method(self, state, *args, **kwargs)
File “/usr/local/lib/python3.6/dist-packages/prefect/engine/flow_runner.py”, line 393, in get_flow_run_state
with executor.start():
File “/usr/lib/python3.6/contextlib.py”, line 81, in enter
return next(self.gen)
File “/usr/local/lib/python3.6/dist-packages/prefect/engine/executors/dask.py”, line 74, in start
self.address, processes=self.local_processes, **self.kwargs
File “/usr/local/lib/python3.6/dist-packages/distributed/client.py”, line 651, in init
“Unexpected keyword arguments: {}“.format(str(sorted(kwargs)))
ValueError: Unexpected keyword arguments: [‘processes’, ‘silence_logs’] when trying to connect to a local dask scheduler created using KubeCluster()