Skip to content

Commit bf61fbc

Browse files
committed
Fixed #111 -- move new_nodes out of conditional and delete nodes properly.
1 parent fd23fc5 commit bf61fbc

3 files changed

Lines changed: 3 additions & 7 deletions

File tree

api/models.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -261,13 +261,13 @@ def scale_layers(self, **kwargs):
261261
"""Scale layers up or down to match requested."""
262262
layers = self.layers.copy()
263263
funcs = []
264+
new_nodes = False
264265
for layer_id, requested in layers.items():
265266
layer = self.layer_set.get(id=layer_id)
266267
nodes = list(layer.node_set.all().order_by('created'))
267268
diff = requested - len(nodes)
268269
if diff == 0:
269270
continue
270-
new_nodes = False
271271
while diff < 0:
272272
node = nodes.pop(0)
273273
funcs.append(node.terminate)

api/views.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,6 @@ def get_object(self, *args, **kwargs):
304304
def destroy(self, request, **kwargs):
305305
node = self.get_object()
306306
node.destroy()
307-
node.delete()
308307
return Response(status=status.HTTP_204_NO_CONTENT)
309308

310309

celerytasks/ec2.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -136,13 +136,10 @@ def terminate_node(node_id, creds, params, provider_id):
136136
i.update()
137137
if i.state == "terminated":
138138
break
139-
# pull the node from the database
139+
# delete the node from the database
140140
node = Node.objects.get(uuid=node_id)
141141
chef_id = node.id
142-
node.provider_id = None
143-
node.fqdn = None
144-
node.metadata = {}
145-
node.save()
142+
node.delete()
146143
# purge the node & client records from chef server
147144
client = ChefAPI(settings.CHEF_SERVER_URL,
148145
settings.CHEF_CLIENT_NAME,

0 commit comments

Comments
 (0)