Skip to content

Commit

Permalink
Remove init from async hook
Browse files Browse the repository at this point in the history
  • Loading branch information
pankajastro committed Mar 13, 2023
1 parent 4dd2f17 commit a407e4c
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions airflow/providers/amazon/aws/hooks/base_aws.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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(
Expand Down

0 comments on commit a407e4c

Please sign in to comment.