Add tests to exercise the explicit default

Author: nateprewitt

sdk/storage/azure-storage-blob/tests/test_block_blob.py

@@ -1984,4 +1984,21 @@ def test_upload_blob_copy_source_error_and_status_code(self, **kwargs):
         finally:
             self.bsc.delete_container(self.container_name)
 
+    @pytest.mark.live_test_only
+    @BlobPreparer()
+    def test_put_block_blob_with_none_concurrency(self, **kwargs):
+        storage_account_name = kwargs.pop("storage_account_name")
+        storage_account_key = kwargs.pop("storage_account_key")
+
+        self._setup(storage_account_name, storage_account_key)
+        blob_name = self._get_blob_reference()
+        blob = self.bsc.get_blob_client(self.container_name, blob_name)
+        data = b'a' * 5 * 1024
+
+        # max_concurrency=None should not raise TypeError
+        blob.upload_blob(data, max_concurrency=None, overwrite=True)
+
+        content = blob.download_blob().readall()
+        assert data == content
+
 #------------------------------------------------------------------------------

sdk/storage/azure-storage-blob/tests/test_block_blob_async.py

@@ -2102,4 +2102,21 @@ async def test_upload_blob_copy_source_error_and_status_code(self, **kwargs):
         finally:
             await self.bsc.delete_container(self.container_name)
 
+    @pytest.mark.live_test_only
+    @BlobPreparer()
+    async def test_put_block_blob_with_none_concurrency(self, **kwargs):
+        storage_account_name = kwargs.pop("storage_account_name")
+        storage_account_key = kwargs.pop("storage_account_key")
+
+        await self._setup(storage_account_name, storage_account_key)
+        blob_name = self._get_blob_reference()
+        blob = self.bsc.get_blob_client(self.container_name, blob_name)
+        data = b'a' * 5 * 1024
+
+        # max_concurrency=None should not raise TypeError
+        await blob.upload_blob(data, max_concurrency=None, overwrite=True)
+
+        content = await (await blob.download_blob()).readall()
+        assert data == content
+
 # ------------------------------------------------------------------------------

sdk/storage/azure-storage-blob/tests/test_get_blob.py

@@ -1663,4 +1663,19 @@ def test_get_blob_read_chars_utf32(self, **kwargs):
         result += stream.readall()
         assert result == data
 
+    @pytest.mark.live_test_only
+    @BlobPreparer()
+    def test_get_blob_to_bytes_with_none_concurrency(self, **kwargs):
+        storage_account_name = kwargs.pop("storage_account_name")
+        storage_account_key = kwargs.pop("storage_account_key")
+
+        self._setup(storage_account_name, storage_account_key)
+        blob = self.bsc.get_blob_client(self.container_name, self.byte_blob)
+
+        # max_concurrency=None should not raise TypeError
+        stream = blob.download_blob(max_concurrency=None)
+        content = stream.readall()
+
+        assert self.byte_data == content
+
     # ------------------------------------------------------------------------------

sdk/storage/azure-storage-blob/tests/test_get_blob_async.py

@@ -1815,4 +1815,19 @@ async def test_get_blob_read_chars_utf32(self, **kwargs):
         result += await stream.readall()
         assert result == data
 
+    @pytest.mark.live_test_only
+    @BlobPreparer()
+    async def test_get_blob_to_bytes_with_none_concurrency(self, **kwargs):
+        storage_account_name = kwargs.pop("storage_account_name")
+        storage_account_key = kwargs.pop("storage_account_key")
+
+        await self._setup(storage_account_name, storage_account_key)
+        blob = self.bsc.get_blob_client(self.container_name, self.byte_blob)
+
+        # max_concurrency=None should not raise TypeError
+        stream = await blob.download_blob(max_concurrency=None)
+        content = await stream.readall()
+
+        assert self.byte_data == content
+
 # ------------------------------------------------------------------------------