diff --git a/airflow/providers/amazon/aws/hooks/base_aws.py b/airflow/providers/amazon/aws/hooks/base_aws.py index 086e656305dfd..d797653476ef6 100644 --- a/airflow/providers/amazon/aws/hooks/base_aws.py +++ b/airflow/providers/amazon/aws/hooks/base_aws.py @@ -54,7 +54,6 @@ from airflow.exceptions import ( AirflowException, AirflowNotFoundException, - AirflowOptionalProviderFeatureException, ) from airflow.hooks.base import BaseHook from airflow.providers.amazon.aws.utils.connection_wrapper import AwsConnectionWrapper @@ -990,15 +989,6 @@ class AwsBaseAsyncHook(AwsBaseHook): :param config: Configuration for botocore client. """ - def __init__(self, **kwargs) -> None: - try: - import aiobotocore - except ImportError: - raise AirflowOptionalProviderFeatureException( - "AWS deferrable operator feature is disable. To enable it please install aiobotocore>=2.1.1" - ) - super().__init__(**kwargs) - def get_async_session(self) -> AioSession: """Get the underlying aiobotocore.session.AioSession(...).""" return BaseAsyncSessionFactory(