Fixed conflicting arguments
This commit is contained in:
parent
219ed45f94
commit
81e615f5c1
1 changed files with 4 additions and 0 deletions
|
|
@ -284,6 +284,10 @@ class SQSBackend(BaseBackend):
|
||||||
def create_queue(self, name, **kwargs):
|
def create_queue(self, name, **kwargs):
|
||||||
queue = self.queues.get(name)
|
queue = self.queues.get(name)
|
||||||
if queue is None:
|
if queue is None:
|
||||||
|
try:
|
||||||
|
kwargs.pop('region')
|
||||||
|
except KeyError:
|
||||||
|
pass
|
||||||
queue = Queue(name, region=self.region_name, **kwargs)
|
queue = Queue(name, region=self.region_name, **kwargs)
|
||||||
self.queues[name] = queue
|
self.queues[name] = queue
|
||||||
return queue
|
return queue
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue