Skip to content

Commit 7ea6036

Browse files
committed
add region_name to boto3.resource('sqs') call in SqsQueueClient
adapt test
1 parent f7e46f6 commit 7ea6036

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

eb_sqs/aws/sqs_queue_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
class SqsQueueClient(QueueClient):
1111
def __init__(self):
1212
# type: () -> None
13-
self.sqs = boto3.resource('sqs')
13+
self.sqs = boto3.resource('sqs', region_name=settings.AWS_REGION)
1414
self.queue_cache = {}
1515

1616
def _get_queue(self, queue_name):

eb_sqs/tests/aws/tests_aws_queue_client.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,13 +6,14 @@
66
import time
77
from moto import mock_sqs
88

9+
from eb_sqs import settings
910
from eb_sqs.aws.sqs_queue_client import SqsQueueClient
1011

1112

1213
class AwsQueueClientTest(TestCase):
1314
@mock_sqs()
1415
def test_add_message(self):
15-
sqs = boto3.resource('sqs')
16+
sqs = boto3.resource('sqs', region_name=settings.AWS_REGION)
1617
queue = sqs.create_queue(QueueName='eb-sqs-default')
1718

1819
queue_client = SqsQueueClient()
@@ -25,7 +26,7 @@ def test_add_message(self):
2526
@mock_sqs()
2627
def test_add_message_delayed(self):
2728
delay = 1
28-
sqs = boto3.resource('sqs')
29+
sqs = boto3.resource('sqs', region_name=settings.AWS_REGION)
2930
queue = sqs.create_queue(QueueName='eb-sqs-default')
3031
queue_client = SqsQueueClient()
3132

0 commit comments

Comments
 (0)