Skip to content

Commit 90192af

Browse files
authored
Merge pull request #19 from cuda-networks/additional_logging
Additional logging
2 parents e19fa45 + 4ad7dc3 commit 90192af

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

eb_sqs/worker/service.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -83,12 +83,12 @@ def delete_messages(self, queue, msg_entries):
8383
# type: (Queue, list) -> None
8484
if len(msg_entries) > 0:
8585
response = queue.delete_messages(Entries=msg_entries)
86-
logger.debug('[django-eb-sqs] Deleted {} messages successfully'.format(
87-
len(response.get('Successful', []))
88-
))
89-
logger.debug('[django-eb-sqs] Failed deleting {} messages'.format(
90-
len(response.get('Failed', []))
91-
))
86+
87+
# logging
88+
failed = response.get('Failed', [])
89+
num_failed = len(failed)
90+
if num_failed > 0:
91+
logger.warning('[django-eb-sqs] Failed deleting {} messages: {}'.format(num_failed, failed))
9292

9393
def poll_messages(self, queue):
9494
# type: (Queue) -> list

0 commit comments

Comments
 (0)