Remove py3.9 syntax

celery · Jan 15, 2025 · dc78076 · dc78076
1 parent d7f9ce5
commit dc78076
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 4 deletions.
diff --git a/kombu/asynchronous/aws/connection.py b/kombu/asynchronous/aws/connection.py
@@ -184,7 +184,8 @@ def __init__(self, sqs_connection, http_client=None,
                          **http_client_params)
 
     def make_request(self, operation, params_, path, verb, callback=None, protocol_params=None):
-        params = params_.copy() | (protocol_params or {}).get('query', {})
+        params = params_.copy()
+        params.update((protocol_params or {}).get('query', {}))
         if operation:
             params['Action'] = operation
         signer = self.sqs_connection._request_signer

diff --git a/kombu/asynchronous/aws/sqs/connection.py b/kombu/asynchronous/aws/sqs/connection.py
@@ -95,7 +95,7 @@ def make_request(self, operation_name, params, queue_url, verb, callback=None, p
 
         service_model = self.sqs_connection.meta.service_model
         protocol = service_model.protocol
-        all_params = (params or {}) | protocol_params.get(protocol, {})
+        all_params = {**(params or {}), **protocol_params.get(protocol, {})}
 
         if protocol == 'query':
             request = self._create_query_request(

diff --git a/t/unit/asynchronous/aws/sqs/test_connection.py b/t/unit/asynchronous/aws/sqs/test_connection.py
@@ -158,7 +158,7 @@ def test_make_request__with_query_protocol(self):
         queue_url = f'{SQS_URL}/123456789012/celery-test'
         verb = 'POST'
 
-        expect_params = params | {'AttributeName.1': 'ApproximateReceiveCount'}
+        expect_params = {**params, 'AttributeName.1': 'ApproximateReceiveCount'}
 
         self.x.make_request(operation, params, queue_url, verb, protocol_params=pparams)
         self.x._create_query_request.assert_called_with(
@@ -186,7 +186,7 @@ def test_make_request__with_json_protocol(self):
 
         queue_url = f'{SQS_URL}/123456789012/celery-test'
         verb = 'POST'
-        expect_params = params | {'AttributeNames': ['ApproximateReceiveCount']}
+        expect_params = {**params, 'AttributeNames': ['ApproximateReceiveCount']}
 
         self.x.make_request(operation, params, queue_url, verb, protocol_params=pparams)
         self.x._create_json_request.assert_called_with(