Skip to content

Commit

Permalink
output queue name
Browse files Browse the repository at this point in the history
  • Loading branch information
jsjiang committed Nov 1, 2024
1 parent b8e72bb commit 537debc
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions ezidapp/management/commands/proc-cleanup-async-queues_v2.py
Original file line number Diff line number Diff line change
Expand Up @@ -196,8 +196,7 @@ def deleteRecord(self, queue, primary_key, record_type=None, identifier=None):
try:
# check if the record to be deleted is a refIdentifier record
if (record_type is not None and record_type == 'refId'):
log.info(type(queue))
log.info("Delete refId: " + str(primary_key))
log.info(f"Delete from {queue.__name__} refId: " + str(primary_key))
with transaction.atomic():
obj = queue.objects.select_for_update().get(id=primary_key)
obj.delete()
Expand Down

0 comments on commit 537debc

Please sign in to comment.