diff options
| author | Jayme Howard <jayme@reddit.com> | 2020-04-14 14:57:42 -0500 |
|---|---|---|
| committer | Asif Saif Uddin <auvipy@gmail.com> | 2020-04-15 10:03:10 +0600 |
| commit | 472101103e5ead37ad637beb7361aa1b3a32e389 (patch) | |
| tree | 67c620392ba01fb19ea857ef04c7a1d98ae9b14c | |
| parent | 453e0e9aeb606373252ad9c4a70c947dd38b9b45 (diff) | |
| download | kombu-472101103e5ead37ad637beb7361aa1b3a32e389.tar.gz | |
Prevent failure if AWS creds are not explicitly defined on predefined_queues
| -rw-r--r-- | kombu/transport/SQS.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index 9687f61b..83a436de 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -527,8 +527,8 @@ class Channel(virtual.Channel): q = self.predefined_queues[queue] c = self._predefined_queue_clients[queue] = self.new_sqs_client( region=q.get('region', self.region), - access_key_id=q['access_key_id'] or self.conninfo.userid, - secret_access_key=q['secret_access_key'] or self.conninfo.password, # noqa: E501 + access_key_id=q.get('access_key_id', self.conninfo.userid), + secret_access_key=q.get('secret_access_key', self.conninfo.password), # noqa: E501 ) return c |