from operator import attrgetter
import libcloud.common.types as cloud_types
-from libcloud.compute.base import NodeDriver
+from libcloud.compute.base import NodeDriver, NodeAuthSSHKey
from ...config import NETWORK_ERRORS
def _init_ssh_key(self, filename):
with open(filename) as ssh_file:
- key = cloud_base.NodeAuthSSHKey(ssh_file.read())
+ key = NodeAuthSSHKey(ssh_file.read())
return 'auth', key
def search_for(self, term, list_method, key=attrgetter('id'), **kwargs):
"""
raise NotImplementedError("BaseComputeNodeDriver.arvados_create_kwargs")
+ def broken(self, cloud_node):
+ """Return true if libcloud has indicated the node is in a "broken" state."""
+ return False
+
def _make_ping_url(self, arvados_node):
return 'https://{}/arvados/v1/nodes/{}/ping?ping_secret={}'.format(
self.ping_host, arvados_node['uuid'],