implement simple retries for wayward inventory deletes

This commit is contained in:
Ryan Petrello 2018-10-19 09:55:39 -04:00
parent cce470a5f8
commit 9316c9ea3e
No known key found for this signature in database
GPG Key ID: F2AA5F2122351777

View File

@ -566,7 +566,7 @@ def update_host_smart_inventory_memberships():
@task() @task()
def delete_inventory(inventory_id, user_id): def delete_inventory(inventory_id, user_id, retries=5):
# Delete inventory as user # Delete inventory as user
if user_id is None: if user_id is None:
user = None user = None
@ -591,7 +591,9 @@ def delete_inventory(inventory_id, user_id):
return return
except DatabaseError: except DatabaseError:
logger.exception('Database error deleting inventory {}, but will retry.'.format(inventory_id)) logger.exception('Database error deleting inventory {}, but will retry.'.format(inventory_id))
# TODO: self.retry(countdown=10) if retries > 0:
time.sleep(10)
delete_inventory(inventory_id, user_id, retries=retries - 1)
def with_path_cleanup(f): def with_path_cleanup(f):