@@ -45,23 +45,23 @@ def stop(self, aws_tags: List[Dict]) -> None:
45
45
"""
46
46
tag_key = aws_tags [0 ]["Key" ]
47
47
tag_value = "" .join (aws_tags [0 ]["Values" ])
48
- asg_list = self .list_groups (tag_key , tag_value )
49
- instance_list = self .list_instances (asg_list )
48
+ asg_name_list = self .list_groups (tag_key , tag_value )
49
+ instance_id_list = self .list_instances (asg_name_list )
50
50
51
- for asg_name in asg_list :
51
+ for asg_name in asg_name_list :
52
52
try :
53
53
self .asg .suspend_processes (AutoScalingGroupName = asg_name )
54
54
print ("Suspend autoscaling group {0}" .format (asg_name ))
55
55
except ClientError as exc :
56
56
ec2_exception ("instance" , asg_name , exc )
57
57
58
58
# Stop autoscaling instance
59
- for ec2_instance in instance_list :
59
+ for instance_id in instance_id_list :
60
60
try :
61
- self .ec2 .stop_instances (InstanceIds = [ec2_instance ])
62
- print ("Stop autoscaling instances {0}" .format (ec2_instance ))
61
+ self .ec2 .stop_instances (InstanceIds = [instance_id ])
62
+ print ("Stop autoscaling instances {0}" .format (instance_id ))
63
63
except ClientError as exc :
64
- ec2_exception ("autoscaling group" , ec2_instance , exc )
64
+ ec2_exception ("autoscaling group" , instance_id , exc )
65
65
66
66
def start (self , aws_tags : List [Dict ]) -> None :
67
67
"""Aws autoscaling resume function.
@@ -83,23 +83,23 @@ def start(self, aws_tags: List[Dict]) -> None:
83
83
"""
84
84
tag_key = aws_tags [0 ]["Key" ]
85
85
tag_value = "" .join (aws_tags [0 ]["Values" ])
86
- asg_list = self .list_groups (tag_key , tag_value )
87
- instance_list = self .list_instances (asg_list )
86
+ asg_name_list = self .list_groups (tag_key , tag_value )
87
+ instance_id_list = self .list_instances (asg_name_list )
88
88
instance_running_ids = []
89
89
90
90
# Start autoscaling instance
91
- for ec2_instance in instance_list :
91
+ for instance_id in instance_id_list :
92
92
try :
93
- self .ec2 .start_instances (InstanceIds = [ec2_instance ])
94
- print ("Start autoscaling instances {0}" .format (ec2_instance ))
93
+ self .ec2 .start_instances (InstanceIds = [instance_id ])
94
+ print ("Start autoscaling instances {0}" .format (instance_id ))
95
95
except ClientError as exc :
96
- ec2_exception ("instance" , ec2_instance , exc )
96
+ ec2_exception ("instance" , instance_id , exc )
97
97
else :
98
- instance_running_ids .append (ec2_instance )
98
+ instance_running_ids .append (instance_id )
99
99
100
100
self .waiter .instance_running (instance_ids = instance_running_ids )
101
101
102
- for asg_name in asg_list :
102
+ for asg_name in asg_name_list :
103
103
try :
104
104
self .asg .resume_processes (AutoScalingGroupName = asg_name )
105
105
print ("Resume autoscaling group {0}" .format (asg_name ))
@@ -117,36 +117,36 @@ def list_groups(self, tag_key: str, tag_value: str) -> List[str]:
117
117
:param str tag_value:
118
118
Aws tag value to use for filter resources
119
119
120
- :return list asg_list :
120
+ :return list asg_name_list :
121
121
The names of the Auto Scaling groups
122
122
"""
123
- asg_list = []
123
+ asg_name_list = []
124
124
paginator = self .asg .get_paginator ("describe_auto_scaling_groups" )
125
125
126
126
for page in paginator .paginate ():
127
127
for group in page ["AutoScalingGroups" ]:
128
128
for tag in group ["Tags" ]:
129
129
if tag ["Key" ] == tag_key and tag ["Value" ] == tag_value :
130
- asg_list .append (group ["AutoScalingGroupName" ])
131
- return asg_list
130
+ asg_name_list .append (group ["AutoScalingGroupName" ])
131
+ return asg_name_list
132
132
133
- def list_instances (self , asg_list : List [str ]) -> Iterator [str ]:
133
+ def list_instances (self , asg_name_list : List [str ]) -> Iterator [str ]:
134
134
"""Aws autoscaling instance list function.
135
135
136
136
List name of all instances in the autoscaling groups
137
137
and return it in list.
138
138
139
- :param list asg_list :
139
+ :param list asg_name_list :
140
140
The names of the Auto Scaling groups.
141
141
142
142
:yield Iterator[str]:
143
143
The names of the instances in Auto Scaling groups.
144
144
"""
145
- if not asg_list :
145
+ if not asg_name_list :
146
146
return iter ([])
147
147
paginator = self .asg .get_paginator ("describe_auto_scaling_groups" )
148
148
149
- for page in paginator .paginate (AutoScalingGroupNames = asg_list ):
149
+ for page in paginator .paginate (AutoScalingGroupNames = asg_name_list ):
150
150
for scalinggroup in page ["AutoScalingGroups" ]:
151
151
for instance in scalinggroup ["Instances" ]:
152
152
yield instance ["InstanceId" ]
0 commit comments