We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4badf8d commit 0f215deCopy full SHA for 0f215de
1 file changed
taskiq_sqs/broker.py
@@ -49,7 +49,9 @@ async def _get_queue(self) -> Queue:
49
queue_name = self.sqs_queue_url.split("/")[-1]
50
51
if not self._sqs_queue:
52
- self._sqs_queue = await asyncify(self._sqs.get_queue_by_name)(QueueName=queue_name)
+ self._sqs_queue = await asyncify(self._sqs.get_queue_by_name)(
53
+ QueueName=queue_name
54
+ )
55
56
57
raise Exception("SQS Queue not found")
0 commit comments