update delete_inventory task

This commit is contained in:
Wayne Witzel III 2017-06-29 00:15:56 -04:00
parent 0204fc1347
commit e9235d8b54

View File

@ -360,18 +360,17 @@ def update_host_smart_inventory_memberships():
def delete_inventory(inventory_id):
with ignore_inventory_computed_fields(), \
ignore_inventory_group_removal():
with transaction.atomic():
try:
i = Inventory.objects.get(id=inventory_id)
except Inventory.DoesNotExist:
logger.error("Delete Inventory failed due to missing inventory: " + str(inventory_id))
return
try:
i = Inventory.objects.get(id=inventory_id)
i.delete()
emit_channel_notification(
'inventories-status_changed',
{'group_name': 'inventories', 'inventory_id': inventory_id, 'status': 'deleted'}
)
logger.debug('Deleted inventory: %s' % inventory_id)
emit_channel_notification(
'inventories-status_changed',
{'group_name': 'inventories', 'inventory_id': inventory_id, 'status': 'deleted'}
)
logger.debug('Deleted inventory: %s' % inventory_id)
except Inventory.DoesNotExist:
logger.error("Delete Inventory failed due to missing inventory: " + str(inventory_id))
return
class BaseTask(Task):