self.tags = {key[4:]: value
for key, value in list_kwargs.iteritems()
if key.startswith('tag:')}
+ # Tags are assigned at instance creation time
+ if not 'ex_metadata' in create_kwargs:
+ create_kwargs['ex_metadata'] = {}
+ create_kwargs['ex_metadata'].update(self.tags)
super(ComputeNodeDriver, self).__init__(
auth_kwargs, {'ex_filters': list_kwargs}, create_kwargs,
driver_class)
}}]
return kw
- def post_create_node(self, cloud_node):
- self.real.ex_create_tags(cloud_node, self.tags)
-
def sync_node(self, cloud_node, arvados_node):
self.real.ex_create_tags(cloud_node,
{'Name': arvados_node_fqdn(arvados_node)})