Skip to content

Commit 08ae187

Browse files
author
Gabriel Monroy
committed
only delete records from the view, fix chef_id issue
1 parent 7d52dec commit 08ae187

3 files changed

Lines changed: 13 additions & 18 deletions

File tree

api/models.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -447,7 +447,6 @@ def destroy(self):
447447
# call a celery task to update the formation data bag
448448
if settings.CHEF_ENABLED:
449449
controller.destroy_formation.delay(self.id).wait() # @UndefinedVariable
450-
self.delete()
451450

452451

453452
@python_2_unicode_compatible
@@ -504,8 +503,6 @@ def destroy(self, async=False):
504503
# destroy nodes, then the layer
505504
node_tasks.apply_async().join()
506505
layer_tasks.apply_async().join()
507-
# delete the database record
508-
self.delete()
509506

510507

511508
@python_2_unicode_compatible

api/views.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,8 @@ def converge(self, request, **kwargs):
227227

228228
def destroy(self, request, **kwargs):
229229
formation = self.get_object()
230-
formation.destroy() # destroy will delete the record
230+
formation.destroy()
231+
formation.delete()
231232
return Response(status=status.HTTP_204_NO_CONTENT)
232233

233234

@@ -264,11 +265,12 @@ def create(self, request, **kwargs):
264265

265266
def post_save(self, layer, created=False, **kwargs):
266267
if created:
267-
layer.build() # build the layer's infrastructure
268+
layer.build()
268269

269270
def destroy(self, request, **kwargs):
270271
layer = self.get_object()
271-
layer.destroy() # destroy layer infrastructure and delete
272+
layer.destroy()
273+
layer.delete()
272274
return Response(status=status.HTTP_204_NO_CONTENT)
273275

274276

@@ -290,7 +292,8 @@ def get_object(self, *args, **kwargs):
290292

291293
def destroy(self, request, **kwargs):
292294
node = self.get_object()
293-
node.destroy() # destroy will delete the record
295+
node.destroy()
296+
node.delete()
294297
return Response(status=status.HTTP_204_NO_CONTENT)
295298

296299

celerytasks/ec2.py

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -134,17 +134,12 @@ def terminate_node(node_id, creds, params, provider_id):
134134
if i.state == "terminated":
135135
break
136136
# pull the node from the database
137-
try:
138-
node = Node.objects.get(uuid=node_id)
139-
chef_id = node.id
140-
node.provider_id = None
141-
node.fqdn = None
142-
node.metadata = {}
143-
node.save()
144-
# delete the node itself from the database
145-
node.delete()
146-
except Node.DoesNotExist:
147-
pass # ignore node does not exist
137+
node = Node.objects.get(uuid=node_id)
138+
chef_id = node.id
139+
node.provider_id = None
140+
node.fqdn = None
141+
node.metadata = {}
142+
node.save()
148143
# purge the node & client records from chef server
149144
client = ChefAPI(settings.CHEF_SERVER_URL,
150145
settings.CHEF_CLIENT_NAME,

0 commit comments

Comments
 (0)