SQS: redevelivered - updated unit tests

celery · Jul 2, 2024 · 25af503 · 25af503
1 parent 64fa88c
commit 25af503
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/t/unit/transport/test_SQS.py b/t/unit/transport/test_SQS.py
@@ -408,7 +408,9 @@ def test_redelivered(self):
             'properties': {'delivery_tag': 'test_message_id'}
         }
         self.channel._put(self.producer.routing_key, message)
-        self.sqs_conn_mock.change_message_visibility.assert_called_once()
+        self.sqs_conn_mock.change_message_visibility.assert_called_once_with(
+            QueueUrl='https://sqs.us-east-1.amazonaws.com/xxx/unittestq',
+            ReceiptHandle='test_message_id', VisibilityTimeout=10)
 
     def test_put_and_get_bulk(self):
         # With QoS.prefetch_count = 0