File tree Expand file tree Collapse file tree 1 file changed +0
-10
lines changed
airflow/providers/amazon/aws/hooks Expand file tree Collapse file tree 1 file changed +0
-10
lines changed Original file line number Diff line number Diff line change 54
54
from airflow .exceptions import (
55
55
AirflowException ,
56
56
AirflowNotFoundException ,
57
- AirflowOptionalProviderFeatureException ,
58
57
)
59
58
from airflow .hooks .base import BaseHook
60
59
from airflow .providers .amazon .aws .utils .connection_wrapper import AwsConnectionWrapper
@@ -990,15 +989,6 @@ class AwsBaseAsyncHook(AwsBaseHook):
990
989
:param config: Configuration for botocore client.
991
990
"""
992
991
993
- def __init__ (self , ** kwargs ) -> None :
994
- try :
995
- import aiobotocore
996
- except ImportError :
997
- raise AirflowOptionalProviderFeatureException (
998
- "AWS deferrable operator feature is disable. To enable it please install aiobotocore>=2.1.1"
999
- )
1000
- super ().__init__ (** kwargs )
1001
-
1002
992
def get_async_session (self ) -> AioSession :
1003
993
"""Get the underlying aiobotocore.session.AioSession(...)."""
1004
994
return BaseAsyncSessionFactory (
You can’t perform that action at this time.
0 commit comments