Lines Matching refs:instance_group
43 self, ec2_instance_id, instance_group, instance_fleet_id=None, id=None, argument
47 self.instance_group = instance_group
333 def add_instance_group(self, instance_group): argument
334 if instance_group.role == "MASTER":
337 self.master_instance_group_id = instance_group.id
338 num_master_nodes = instance_group.num_instances
347 if instance_group.role == "CORE":
350 self.core_instance_group_id = instance_group.id
351 self.instance_group_ids.append(instance_group.id)
427 for instance_group in instance_groups:
428 group = FakeInstanceGroup(cluster_id=cluster_id, **instance_group)
434 def add_instances(self, cluster_id, instances, instance_group): argument
441 ec2_instance_id=instance.id, instance_group=instance_group,
550 groups = [g for g in groups if g.instance_group.id == instance_group_id]
553 g for g in groups if g.instance_group.role in instance_group_types
579 for instance_group in instance_groups:
580 group = self.instance_groups[instance_group["instance_group_id"]]
581 group.set_instance_count(int(instance_group["instance_count"]))
667 instance_group = instance_groups[0]
668 instance_group.auto_scaling_policy = auto_scaling_policy
669 return instance_group
677 instance_group = instance_groups[0]
678 instance_group.auto_scaling_policy = None