Skip to content

Commit a87b562

Browse files
author
Alexey Tsitkin
committed
minor fix
1 parent 889f9f6 commit a87b562

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

eb_sqs/worker/service.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,9 @@ def process_messages(self, queues, worker):
7575
'ReceiptHandle': msg.receipt_handle
7676
})
7777

78-
queue.delete_messages(Entries=msg_entries)
79-
logger.debug('[django-eb-sqs] Deleted {} messages'.format(len(messages)))
78+
if len(messages) > 0:
79+
queue.delete_messages(Entries=msg_entries)
80+
logger.debug('[django-eb-sqs] Deleted {} messages'.format(len(messages)))
8081
except Exception as exc:
8182
logger.warning('[django-eb-sqs] Error polling queue {}: {}'.format(queue.url, exc), exc_info=1)
8283

0 commit comments

Comments
 (0)