temporary commit

Author: Alexey Tsitkin

eb_sqs/worker/service.py

@@ -101,8 +101,10 @@ def poll_messages(self, queue):
     def process_message(self, msg, worker):
         # type: (Message, Worker) -> None
         logger.debug('[django-eb-sqs] Read message {}'.format(msg.message_id))
+        if msg.attributes:
+            print('Retry number {}'.format(msg.attributes.get('ApproximateReceiveCount', 0)))
         sleep(10)
-        print('Retry number {}'.format(msg.attributes.get('ApproximateReceiveCount', 0)))
+
         # try:
         #     worker.execute(msg.body)
         #     logger.debug('[django-eb-sqs] Processed message {}'.format(msg.message_id))