diff --git a/sdk/storage/azure-storage-file/azure/storage/file/_shared/base_client_async.py b/sdk/storage/azure-storage-file/azure/storage/file/_shared/base_client_async.py
index 7f1d67dc31db..b8e947938127 100644
--- a/sdk/storage/azure-storage-file/azure/storage/file/_shared/base_client_async.py
+++ b/sdk/storage/azure-storage-file/azure/storage/file/_shared/base_client_async.py
@@ -11,11 +11,6 @@
 import logging
 
 from azure.core.pipeline import AsyncPipeline
-try:
-    from azure.core.pipeline.transport import AioHttpTransport as AsyncTransport
-except ImportError:
-    from azure.core.pipeline.transport import AsyncioRequestsTransport as AsyncTransport
-
 from azure.core.pipeline.policies.distributed_tracing import DistributedTracingPolicy
 from azure.core.pipeline.policies import (
     ContentDecodePolicy,
@@ -61,7 +56,7 @@ def _create_pipeline(self, credential, **kwargs):
         elif isinstance(credential, SharedKeyCredentialPolicy):
             credential_policy = credential
         elif credential is not None:
-            raise TypeError("Unsupported credential: {}".format(credential))        
+            raise TypeError("Unsupported credential: {}".format(credential))
         config = kwargs.get('_configuration') or create_configuration(**kwargs)
         if kwargs.get('_pipeline'):
             return config, kwargs['_pipeline']
@@ -69,7 +64,8 @@ def _create_pipeline(self, credential, **kwargs):
         if 'connection_timeout' not in kwargs:
             kwargs['connection_timeout'] = DEFAULT_SOCKET_TIMEOUT[0] # type: ignore
         if not config.transport:
-            config.transport = AsyncTransport(**kwargs)
+            from azure.core.pipeline.transport import AioHttpTransport
+            config.transport = AioHttpTransport(**kwargs)
         policies = [
             QueueMessagePolicy(),
             config.headers_policy,
diff --git a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/base_client_async.py b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/base_client_async.py
index 90f22450e6c3..b8e947938127 100644
--- a/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/base_client_async.py
+++ b/sdk/storage/azure-storage-queue/azure/storage/queue/_shared/base_client_async.py
@@ -11,10 +11,6 @@
 import logging
 
 from azure.core.pipeline import AsyncPipeline
-try:
-    from azure.core.pipeline.transport import AioHttpTransport as AsyncTransport
-except ImportError:
-    from azure.core.pipeline.transport import AsyncioRequestsTransport as AsyncTransport
 from azure.core.pipeline.policies.distributed_tracing import DistributedTracingPolicy
 from azure.core.pipeline.policies import (
     ContentDecodePolicy,
@@ -60,7 +56,7 @@ def _create_pipeline(self, credential, **kwargs):
         elif isinstance(credential, SharedKeyCredentialPolicy):
             credential_policy = credential
         elif credential is not None:
-            raise TypeError("Unsupported credential: {}".format(credential))        
+            raise TypeError("Unsupported credential: {}".format(credential))
         config = kwargs.get('_configuration') or create_configuration(**kwargs)
         if kwargs.get('_pipeline'):
             return config, kwargs['_pipeline']
@@ -68,7 +64,8 @@ def _create_pipeline(self, credential, **kwargs):
         if 'connection_timeout' not in kwargs:
             kwargs['connection_timeout'] = DEFAULT_SOCKET_TIMEOUT[0] # type: ignore
         if not config.transport:
-            config.transport = AsyncTransport(**kwargs)
+            from azure.core.pipeline.transport import AioHttpTransport
+            config.transport = AioHttpTransport(**kwargs)
         policies = [
             QueueMessagePolicy(),
             config.headers_policy,