Skip to content

Commit f2e4e97

Browse files
author
Alexey Tsitkin
committed
change log order
1 parent 4db9e19 commit f2e4e97

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

eb_sqs/worker/service.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -104,14 +104,14 @@ def process_message(self, msg, worker):
104104
# type: (Message, Worker) -> None
105105
logger.debug('[django-eb-sqs] Read message {}'.format(msg.message_id))
106106
try:
107-
worker.execute(msg.body)
108-
logger.debug('[django-eb-sqs] Processed message {}'.format(msg.message_id))
109-
110107
receive_count = int(msg.attributes[self._RECEIVE_COUNT_ATTRIBUTE])
111108
if receive_count > 1:
112109
logger.warning('[django-eb-sqs] SQS re-queued message {} times: Msg Id: {} Body: {}'.format(
113110
receive_count, msg.message_id, msg.body
114111
))
112+
113+
worker.execute(msg.body)
114+
logger.debug('[django-eb-sqs] Processed message {}'.format(msg.message_id))
115115
except Exception as exc:
116116
logger.error('[django-eb-sqs] Unhandled error: {}'.format(exc), exc_info=1)
117117

0 commit comments

Comments
 (0)