Surpress boto WARNING during decode, reference: boto/boto#2965

rallytime · Mar 13, 2018 · a8ffced · a8ffced
1 parent 0e90c8c
commit a8ffced
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/salt/engines/sqs_events.py b/salt/engines/sqs_events.py
@@ -165,4 +165,6 @@ def start(queue, profile=None, tag='salt/engine/sqs', owner_acct_id=None):
     while True:
         if not q:
             q = sqs.get_queue(queue, owner_acct_id=owner_acct_id)
+            q.set_message_class(boto.sqs.message.RawMessage)
+
         _process_queue(q, queue, fire_master, tag=tag, owner_acct_id=owner_acct_id, message_format=message_format)