Skip to content

Commit b284913

Browse files
author
Alexey Tsitkin
committed
fixed prints
1 parent 3abaff7 commit b284913

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

eb_sqs/worker/service.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,12 @@ def process_messages(self, queues, worker):
7777

7878
if len(messages) > 0:
7979
response = queue.delete_messages(Entries=msg_entries)
80-
logger.debug('[django-eb-sqs] Deleted {} messages successfully'.format(len(response['Successful'])))
81-
logger.debug('[django-eb-sqs] Failed deleting {} messages'.format(len(response['Failed'])))
80+
logger.debug('[django-eb-sqs] Deleted {} messages successfully'.format(
81+
len(response.get('Successful', []))
82+
))
83+
logger.debug('[django-eb-sqs] Failed deleting {} messages'.format(
84+
len(response.get('Failed', []))
85+
))
8286
except Exception as exc:
8387
logger.warning('[django-eb-sqs] Error polling queue {}: {}'.format(queue.url, exc), exc_info=1)
8488

0 commit comments

Comments
 (0)