fix unreachable mypy warnings for microsoft/azure

Author: fweilun

providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/msgraph.py

@@ -437,7 +437,7 @@ def request_information(
         method: str = "GET",
         query_parameters: dict[str, Any] | None = None,
         headers: dict[str, str] | None = None,
-        data: dict[str, Any] | str | BytesIO | None = None,
+        data: dict[str, Any] | str | bytes | BytesIO | None = None,
     ) -> RequestInformation:
         request_information = RequestInformation()
         request_information.path_parameters = path_parameters or {}

providers/microsoft/azure/src/airflow/providers/microsoft/azure/hooks/wasb.py

@@ -56,6 +56,7 @@
 
 if TYPE_CHECKING:
     from azure.core.credentials import TokenCredential
+    from azure.core.credentials_async import AsyncTokenCredential
     from azure.storage.blob._models import BlobProperties
     from azure.storage.blob.aio._list_blobs_helper import BlobPrefix
 
@@ -590,7 +591,7 @@ def __init__(
         """Initialize the hook instance."""
         self.conn_id = wasb_conn_id
         self.public_read = public_read
-        self.blob_service_client: AsyncBlobServiceClient = None  # type: ignore
+        self.blob_service_client: AsyncBlobServiceClient | None = None  # type: ignore
 
     async def get_async_conn(self) -> AsyncBlobServiceClient:
         """Return the Async BlobServiceClient object."""
@@ -614,8 +615,9 @@ async def get_async_conn(self) -> AsyncBlobServiceClient:
         tenant = self._get_field(extra, "tenant_id")
         if tenant:
             # use Active Directory auth
-            app_id = conn.login
-            app_secret = conn.password
+            app_id: str = conn.login or ""
+            app_secret: str = conn.password or ""
+
             token_credential = AsyncClientSecretCredential(
                 tenant, app_id, app_secret, **client_secret_auth_config
             )
@@ -652,6 +654,7 @@ async def get_async_conn(self) -> AsyncBlobServiceClient:
             return self.blob_service_client
 
         # Fall back to old auth (password) or use managed identity if not provided.
+        credential: str | AsyncTokenCredential | None
         credential = conn.password
         if not credential:
             # Check for account_key in extra fields before falling back to DefaultAzureCredential
@@ -681,6 +684,9 @@ def _get_blob_client(self, container_name: str, blob_name: str) -> AsyncBlobClie
         :param container_name: the name of the blob container
         :param blob_name: the name of the blob. This needs not be existing
         """
+        if self.blob_service_client is None:
+            raise AirflowException("BlobServiceClient is not initialized")
+
         return self.blob_service_client.get_blob_client(container=container_name, blob=blob_name)
 
     async def check_for_blob_async(self, container_name: str, blob_name: str, **kwargs: Any) -> bool:
@@ -704,6 +710,9 @@ def _get_container_client(self, container_name: str) -> AsyncContainerClient:  #
 
         :param container_name: the name of the container
         """
+        if self.blob_service_client is None:
+            raise AirflowException("BlobServiceClient is not initialized")
+
         return self.blob_service_client.get_container_client(container_name)
 
     async def get_blobs_list_async(

providers/microsoft/azure/src/airflow/providers/microsoft/azure/operators/msgraph.py

@@ -247,7 +247,7 @@ def execute_complete(
     @classmethod
     def append_result(
         cls,
-        results: list[Any],
+        results: Any,
         result: Any,
         append_result_as_list_if_absent: bool = False,
     ) -> list[Any]:

providers/microsoft/azure/src/airflow/providers/microsoft/azure/operators/synapse.py

@@ -88,7 +88,7 @@ def __init__(
         **kwargs,
     ) -> None:
         super().__init__(**kwargs)
-        self.job_id = None
+        self.job_id: Any = None
         self.azure_synapse_conn_id = azure_synapse_conn_id
         self.wait_for_termination = wait_for_termination
         self.spark_pool = spark_pool

providers/microsoft/azure/src/airflow/providers/microsoft/azure/secrets/key_vault.py

@@ -100,15 +100,18 @@ def __init__(
     ) -> None:
         super().__init__()
         self.vault_url = vault_url
-        if connections_prefix is not None:
+        self.connections_prefix: str | None
+        if connections_prefix:
             self.connections_prefix = connections_prefix.rstrip(sep)
         else:
             self.connections_prefix = connections_prefix
-        if variables_prefix is not None:
+        self.variables_prefix: str | None
+        if variables_prefix:
             self.variables_prefix = variables_prefix.rstrip(sep)
         else:
             self.variables_prefix = variables_prefix
-        if config_prefix is not None:
+        self.config_prefix: str | None
+        if config_prefix:
             self.config_prefix = config_prefix.rstrip(sep)
         else:
             self.config_prefix = config_prefix