[Storage] Fixed next-mypy for azure-storage-blob, azure-storage-file-share, and azure-storage-queue (Azure#38835)

Author: weirongw23-msft

sdk/storage/azure-storage-blob/azure/storage/blob/_download.py

@@ -116,7 +116,7 @@ def __init__(
 
         # For a parallel download, the stream is always seekable, so we note down the current position
         # in order to seek to the right place when out-of-order chunks come in
-        self.stream_start = stream.tell() if parallel else None
+        self.stream_start = stream.tell() if parallel else 0
 
         # Download progress so far
         self.progress_total = current_progress

sdk/storage/azure-storage-blob/azure/storage/blob/_shared/base_client.py

@@ -363,7 +363,7 @@ def __exit__(self, *args):
 
 
 def _format_shared_key_credential(
-    account_name: str,
+    account_name: Optional[str],
     credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "AsyncTokenCredential", TokenCredential]] = None  # pylint: disable=line-too-long
 ) -> Any:
     if isinstance(credential, str):

sdk/storage/azure-storage-blob/samples/blob_samples_authentication.py

@@ -95,6 +95,10 @@ def auth_shared_access_signature(self):
         # Instantiate a BlobServiceClient using a connection string
         from azure.storage.blob import BlobServiceClient
         blob_service_client = BlobServiceClient.from_connection_string(self.connection_string)
+        if blob_service_client.account_name is None:
+            print("Connection string did not provide an account name." + '\n' +
+                  "Test: auth_shared_access_signature")
+            sys.exit(1)
 
         # [START create_sas_token]
         # Create a SAS token to use to authenticate a new client

sdk/storage/azure-storage-blob/samples/blob_samples_authentication_async.py

@@ -91,6 +91,10 @@ async def auth_shared_access_signature_async(self):
         # Instantiate a BlobServiceClient using a connection string
         from azure.storage.blob.aio import BlobServiceClient
         blob_service_client = BlobServiceClient.from_connection_string(self.connection_string)
+        if blob_service_client.account_name is None:
+            print("Connection string did not provide an account name." + '\n' +
+                  "Test: auth_shared_access_signature_async")
+            sys.exit(1)
 
         # [START create_sas_token]
         # Create a SAS token to use to authenticate a new client

sdk/storage/azure-storage-blob/samples/blob_samples_containers.py

@@ -138,6 +138,10 @@ def container_access_policy(self):
 
         # Instantiate a ContainerClient
         container_client = blob_service_client.get_container_client("myaccesscontainer")
+        if container_client.account_name is None:
+            print("Connection string did not provide an account name." + '\n' +
+                  "Test: container_access_policy")
+            sys.exit(1)
 
         try:
             # Create new Container

sdk/storage/azure-storage-blob/samples/blob_samples_containers_async.py

@@ -136,6 +136,10 @@ async def container_access_policy_async(self):
         async with blob_service_client:
             # Instantiate a ContainerClient
             container_client = blob_service_client.get_container_client("myaccesscontainerasync")
+            if container_client.account_name is None:
+                print("Connection string did not provide an account name." + '\n' +
+                      "Test: container_access_policy_async")
+                sys.exit(1)
 
             try:
                 # Create new Container

sdk/storage/azure-storage-file-share/azure/storage/fileshare/_download.py

@@ -65,7 +65,7 @@ def __init__(
 
         # For a parallel download, the stream is always seekable, so we note down the current position
         # in order to seek to the right place when out-of-order chunks come in
-        self.stream_start = stream.tell() if parallel else None
+        self.stream_start = stream.tell() if parallel else 0
 
         # Download progress so far
         self.progress_total = current_progress

sdk/storage/azure-storage-file-share/azure/storage/fileshare/_shared/base_client.py

@@ -363,7 +363,7 @@ def __exit__(self, *args):
 
 
 def _format_shared_key_credential(
-    account_name: str,
+    account_name: Optional[str],
     credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "AsyncTokenCredential", TokenCredential]] = None  # pylint: disable=line-too-long
 ) -> Any:
     if isinstance(credential, str):

sdk/storage/azure-storage-queue/azure/storage/queue/_shared/base_client.py

@@ -363,7 +363,7 @@ def __exit__(self, *args):
 
 
 def _format_shared_key_credential(
-    account_name: str,
+    account_name: Optional[str],
     credential: Optional[Union[str, Dict[str, str], AzureNamedKeyCredential, AzureSasCredential, "AsyncTokenCredential", TokenCredential]] = None  # pylint: disable=line-too-long
 ) -> Any:
     if isinstance(credential, str):

sdk/storage/azure-storage-queue/samples/queue_samples_authentication_async.py

@@ -110,8 +110,8 @@ async def authentication_by_shared_access_signature_async(self):
         from azure.storage.queue import generate_account_sas, ResourceTypes, AccountSasPermissions
 
         sas_token = generate_account_sas(
-            queue_service.account_name,
-            queue_service.credential.account_key,
+            self.account_name,
+            self.access_key,
             resource_types=ResourceTypes(service=True),
             permission=AccountSasPermissions(read=True),
             expiry=datetime.utcnow() + timedelta(hours=1)