Small set of non-blocking changes from b6. (#13690)

- adds EOF whitespace
- renames _id to _session_id
- Adjusts docstring type

Closes #13686

Author: KieranBrantnerMagee

sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_session.py

@@ -30,7 +30,7 @@
 class BaseSession(object):
     def __init__(self, session_id, receiver, encoding="UTF-8"):
         # type: (str, Union[ServiceBusSessionReceiver, ServiceBusSessionReceiverAsync], str) -> None
-        self._id = session_id
+        self._session_id = session_id
         self._receiver = receiver
         self._encoding = encoding
         self._session_start = None
@@ -58,7 +58,7 @@ def session_id(self):
 
         :rtype: str
         """
-        return self._id
+        return self._session_id
 
     @property
     def locked_until_utc(self):
@@ -110,7 +110,7 @@ def get_state(self):
         self._check_live()
         response = self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_GET_SESSION_STATE_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id},
+            {MGMT_REQUEST_SESSION_ID: self._session_id},
             mgmt_handlers.default
         )
         session_state = response.get(MGMT_RESPONSE_SESSION_STATE)
@@ -138,7 +138,7 @@ def set_state(self, state):
         state = state.encode(self._encoding) if isinstance(state, six.text_type) else state
         return self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_SET_SESSION_STATE_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id, MGMT_REQUEST_SESSION_STATE: bytearray(state)},
+            {MGMT_REQUEST_SESSION_ID: self._session_id, MGMT_REQUEST_SESSION_STATE: bytearray(state)},
             mgmt_handlers.default
         )
 
@@ -169,7 +169,7 @@ def renew_lock(self):
         self._check_live()
         expiry = self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_RENEW_SESSION_LOCK_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id},
+            {MGMT_REQUEST_SESSION_ID: self._session_id},
             mgmt_handlers.default
         )
         expiry_timestamp = expiry[MGMT_RESPONSE_RECEIVER_EXPIRATION]/1000.0

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

@@ -60,7 +60,7 @@ async def get_state(self):
         self._check_live()
         response = await self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_GET_SESSION_STATE_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id},
+            {MGMT_REQUEST_SESSION_ID: self._session_id},
             mgmt_handlers.default
         )
         session_state = response.get(MGMT_RESPONSE_SESSION_STATE)
@@ -89,7 +89,7 @@ async def set_state(self, state):
         state = state.encode(self._encoding) if isinstance(state, six.text_type) else state
         return await self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_SET_SESSION_STATE_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id, MGMT_REQUEST_SESSION_STATE: bytearray(state)},
+            {MGMT_REQUEST_SESSION_ID: self._session_id, MGMT_REQUEST_SESSION_STATE: bytearray(state)},
             mgmt_handlers.default
         )
 
@@ -120,7 +120,7 @@ async def renew_lock(self):
         self._check_live()
         expiry = await self._receiver._mgmt_request_response_with_retry(  # pylint: disable=protected-access
             REQUEST_RESPONSE_RENEW_SESSION_LOCK_OPERATION,
-            {MGMT_REQUEST_SESSION_ID: self._id},
+            {MGMT_REQUEST_SESSION_ID: self._session_id},
             mgmt_handlers.default
         )
         expiry_timestamp = expiry[MGMT_RESPONSE_RECEIVER_EXPIRATION]/1000.0

sdk/servicebus/azure-servicebus/azure/servicebus/aio/management/_management_client_async.py

@@ -53,7 +53,7 @@ class ServiceBusAdministrationClient:  #pylint:disable=too-many-public-methods
 
     def __init__(
             self, fully_qualified_namespace: str,
-            credential: Union["AsyncTokenCredential"],
+            credential: "AsyncTokenCredential",
             **kwargs) -> None:
 
         self.fully_qualified_namespace = fully_qualified_namespace

sdk/servicebus/azure-servicebus/tests/async_tests/mgmt_tests/test_mgmt_namespaces_async.py

@@ -22,4 +22,4 @@ async def test_async_mgmt_namespace_get_properties(self, servicebus_namespace_co
         assert properties
         assert properties.messaging_sku == 'Standard'
         # assert properties.name == servicebus_namespace.name
-        # This is disabled pending investigation of why it isn't getting scrubbed despite expected scrubber use.
+        # This is disabled pending investigation of why it isn't getting scrubbed despite expected scrubber use.