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 0f215de commit 2f6960dCopy full SHA for 2f6960d
1 file changed
taskiq_sqs/broker.py
@@ -5,7 +5,7 @@
5
6
import boto3
7
from asyncer import asyncify
8
-from mypy_boto3_sqs.service_resource import Queue, SQSClient
+from mypy_boto3_sqs.service_resource import Queue, SQSServiceResource
9
from taskiq import AsyncBroker
10
from taskiq.abc.result_backend import AsyncResultBackend
11
from taskiq.acks import AckableMessage
@@ -36,7 +36,7 @@ def __init__(
36
raise BrokerError("A valid SQS Queue URL is required")
37
38
self.sqs_queue_url = sqs_queue_url
39
- self._sqs: SQSClient = boto3.resource("sqs")
+ self._sqs: SQSServiceResource = boto3.resource("sqs")
40
self._sqs_queue: Optional[Queue] = None
41
42
if max_number_of_messages > 10:
0 commit comments