def _init_subnet_id(self, subnet_id):
return 'ex_subnet', self.search_for(subnet_id, 'ex_list_subnets')
- def arvados_create_kwargs(self, arvados_node):
- return {'name': arvados_node_fqdn(arvados_node),
+ create_cloud_name = staticmethod(arvados_node_fqdn)
+
+ def arvados_create_kwargs(self, size, arvados_node):
+ kw = {'name': self.create_cloud_name(arvados_node),
'ex_userdata': self._make_ping_url(arvados_node)}
+ # libcloud/ec2 disk sizes are in GB, Arvados/SLURM "scratch" value is in MB
+ scratch = int(size.scratch / 1000) + 1
+ if scratch > size.disk:
+ volsize = scratch - size.disk
+ if volsize < 1:
+ volsize = 1
+ if volsize > 16384:
+ volsize = 16384
+ kw["ex_blockdevicemappings"] = [{
+ "DeviceName": "/dev/xvdt",
+ "Ebs": {
+ "DeleteOnTermination": True,
+ "VolumeSize": volsize,
+ "VolumeType": "gp2"
+ }}]
+ return kw
def post_create_node(self, cloud_node):
self.real.ex_create_tags(cloud_node, self.tags)
time_str = node.extra['launch_time'].split('.', 2)[0] + 'UTC'
return time.mktime(time.strptime(
time_str,'%Y-%m-%dT%H:%M:%S%Z')) - time.timezone
+
+ @classmethod
+ def node_id(cls, node):
+ return node.id