update to uamqp 1.5.0 (#22348)

Author: yunhaoling

sdk/eventhub/azure-eventhub/CHANGELOG.md

@@ -17,6 +17,9 @@ This version and all future versions will require Python 3.7+. Python 2.7 and 3.
 
 ### Other Changes
 
+- Improved token refresh timing to prevent potentially blocking main flow when the token is about to get expired soon.
+- Updated uAMQP dependency to 1.5.0.
+
 ## 5.6.1 (2021-10-06)
 
 ### Bugs Fixed

sdk/eventhub/azure-eventhub/azure/eventhub/_client_base.py

@@ -341,6 +341,7 @@ def _create_auth(self):
             custom_endpoint_hostname=self._config.custom_endpoint_hostname,
             port=self._config.connection_port,
             verify=self._config.connection_verify,
+            refresh_window=300,
         )
 
     def _close_connection(self):

sdk/eventhub/azure-eventhub/azure/eventhub/aio/_client_base_async.py

@@ -205,6 +205,7 @@ async def _create_auth_async(self) -> authentication.JWTTokenAsync:
                 custom_endpoint_hostname=self._config.custom_endpoint_hostname,
                 port=self._config.connection_port,
                 verify=self._config.connection_verify,
+                refresh_window=300,
             )
             await auth.update_token()
             return auth

sdk/eventhub/azure-eventhub/setup.py

@@ -69,6 +69,6 @@
     packages=find_packages(exclude=exclude_packages),
     install_requires=[
         "azure-core<2.0.0,>=1.14.0",
-        "uamqp>=1.4.3,<2.0.0",
+        "uamqp>=1.5.0,<2.0.0",
     ]
 )

sdk/servicebus/azure-servicebus/CHANGELOG.md

@@ -17,6 +17,9 @@ This version and all future versions will require Python 3.7+. Python 2.7 and 3.
 
 ### Other Changes
 
+- Improved token refresh timing to prevent potentially blocking main flow when the token is about to get expired soon.
+- Updated uAMQP dependency to 1.5.0.
+
 ## 7.4.0 (2021-11-09)
 
 ### Features Added

sdk/servicebus/azure-servicebus/azure/servicebus/_common/utils.py

@@ -184,6 +184,7 @@ def create_authentication(client):
         timeout=client._config.auth_timeout,
         http_proxy=client._config.http_proxy,
         transport_type=client._config.transport_type,
+        refresh_window=300,
     )
 
 

sdk/servicebus/azure-servicebus/azure/servicebus/aio/_async_utils.py

@@ -66,6 +66,7 @@ async def create_authentication(client):
         timeout=client._config.auth_timeout,
         http_proxy=client._config.http_proxy,
         transport_type=client._config.transport_type,
+        refresh_window=300,
     )
 
 

sdk/servicebus/azure-servicebus/setup.py

@@ -63,7 +63,7 @@
         'azure',
     ]),
     install_requires=[
-        "uamqp>=1.4.3,<2.0.0",
+        "uamqp>=1.5.0,<2.0.0",
         'azure-common~=1.1',
         'msrest>=0.6.17,<2.0.0',
         'azure-core<2.0.0,>=1.14.0',

shared_requirements.txt

@@ -118,7 +118,7 @@ msrest>=0.6.21
 msrestazure<2.0.0,>=0.4.32
 azure-mgmt-core<2.0.0,>=1.2.0
 requests>=2.18.4
-uamqp~=1.2.0
+uamqp~=1.5.0
 enum34>=1.0.4
 certifi>=2017.4.17
 aiohttp>=3.0
@@ -174,9 +174,9 @@ opentelemetry-sdk<2.0.0,>=1.5.0,!=1.10a0
 #override azure-eventhub-checkpointstoreblob-aio azure-core<2.0.0,>=1.20.1
 #override azure-eventhub-checkpointstoreblob-aio aiohttp<4.0,>=3.0
 #override azure-eventhub-checkpointstoretable azure-core<2.0.0,>=1.14.0
-#override azure-eventhub uamqp>=1.4.3,<2.0.0
+#override azure-eventhub uamqp>=1.5.0,<2.0.0
 #override azure-appconfiguration msrest>=0.6.10
-#override azure-servicebus uamqp>=1.4.3,<2.0.0
+#override azure-servicebus uamqp>=1.5.0,<2.0.0
 #override azure-servicebus msrest>=0.6.17,<2.0.0
 #override azure-servicebus azure-core<2.0.0,>=1.14.0
 #override azure-synapse-accesscontrol azure-core>=1.20.0,<2.0.0