1

I'm trying to use the function remove_cluster of ipyparallel.ClusterManager()

import ipyparallel as ipp
cluster = ipp.Cluster(n=2)
# start cluster syncronously
cluster.start_cluster_sync()
# <Cluster(cluster_id='1648998791-i14e', profile='default', controller=<running>, engine_sets=['1648998792'])>
cluster._is_running()
# True
# remove cluster
ipp.ClusterManager().remove_cluster(cluster_id='1648998791-i14e')

and I get the error message:

---------------------------------------------------------------------------
KeyError                                  Traceback (most recent call last)
<ipython-input-33-fea95f8f114c> in <module>
      1 # remove cluster
----> 2 ipp.ClusterManager().remove_cluster(cluster_id='1648998791-i14e')

/Library/Frameworks/Python.framework/Versions/3.9/lib/python3.9/site-packages/ipyparallel/cluster/cluster.py in remove_cluster(self, cluster_id)
   1039         """Delete a cluster by id"""
   1040         # TODO: check running?
-> 1041         del self.clusters[cluster_id]
   1042 
   1043

I get the same error also if I first stop the cluster. Here's the version of ipyparallel I'm using:

pip show ipyparallel
# Name: ipyparallel
# Version: 8.2.1
Improve this question
Related questions
3
ipcluster3.exe failed to create process
6
Change IPython 3 for Python 3 kernel to python2 for the cluster too
1
Stopping ipcluster engines (IPython Parallel)
Load 7 more related questions Show fewer related questions

0

Reset to default

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.