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 e3aef75 commit 8082165Copy full SHA for 8082165
1 file changed
taskiq_sqs/broker.py
@@ -32,8 +32,8 @@ def __init__(
32
) -> None:
33
super().__init__(result_backend, task_id_generator)
34
35
- if not sqs_queue_url:
36
- raise BrokerError("SQS Queue URL is required")
+ if not sqs_queue_url or not sqs_queue_url.startswith("http"):
+ raise BrokerError("A valid SQS Queue URL is required")
37
38
self.sqs_queue_url = sqs_queue_url
39
self._sqs = boto3.resource("sqs")
0 commit comments