“HelmCluster”对象在从GCE连接到Dask发行版时没有属性'status‘

Question

我已经在gke上部署了dask图表，可以用distributed.Client访问集群。现在我需要用dask_kubernetes.HelmCluster连接到dask集群，但是它会引发这个异常。代码在本地环境中工作，但在GCE中引发异常。集群已经可以使用kubectl访问。

from dask_kubernetes import HelmCluster

cluster = HelmCluster(release_name='my-dask')
Environment:

报告的例外情况：

RuntimeError: Missing dependency kubectl. Please install kubectl following the instructions for your OS. 
Exception ignored in: <function Cluster.__del__ at 0x7fa65a330b80>
Traceback (most recent call last):
  File "/home/michelv_romei/.local/lib/python3.8/site-packages/distributed/deploy/cluster.py", line 196, in __del__
    if self.status != Status.closed:
AttributeError: 'HelmCluster' object has no attribute 'status'

kubectl已经安装好了。

Dask版本: 2021.11.0

Python版本: 3.8.0

Dask-kubernetes版本: 0.11.0和2022.1.0

Answer 1

注意到相应的GitHub问题，问题作者@Vin B.能够通过以下方式解决这个问题：

无论如何，之前我通过gcloud组件安装了kubectl，也许它使kubectl无法从HelmCluster对象访问，通过默认回购重新安装它解决了问题。