Replace try - except pass by contextlib.suppress in providers (#33980)

Author: hussein-awala

airflow/providers/amazon/aws/hooks/s3.py

@@ -41,10 +41,8 @@
 from uuid import uuid4
 
 if TYPE_CHECKING:
-    try:
+    with suppress(ImportError):
         from aiobotocore.client import AioBaseClient
-    except ImportError:
-        pass
 
 from asgiref.sync import sync_to_async
 from boto3.s3.transfer import TransferConfig

airflow/providers/celery/executors/celery_executor_utils.py

@@ -22,6 +22,7 @@
 
 from __future__ import annotations
 
+import contextlib
 import logging
 import math
 import os
@@ -99,15 +100,11 @@ def on_celery_import_modules(*args, **kwargs):
     import airflow.operators.python
     import airflow.operators.subdag  # noqa: F401
 
-    try:
+    with contextlib.suppress(ImportError):
         import numpy  # noqa: F401
-    except ImportError:
-        pass
 
-    try:
+    with contextlib.suppress(ImportError):
         import kubernetes.client  # noqa: F401
-    except ImportError:
-        pass
 
 
 @app.task

airflow/providers/google/cloud/hooks/mlengine.py

@@ -18,6 +18,7 @@
 """This module contains a Google ML Engine Hook."""
 from __future__ import annotations
 
+import contextlib
 import logging
 import random
 import time
@@ -561,10 +562,9 @@ async def _get_link(self, url: str, session: Session):
             headers = {
                 "Authorization": f"Bearer {await token.get()}",
             }
-            try:
+            with contextlib.suppress(AirflowException):
+                # suppress AirflowException because we don't want to raise exception
                 job = await session_aio.get(url=url, headers=headers)
-            except AirflowException:
-                pass  # Because the job may not be visible in system yet
 
         return job
 

airflow/providers/google/cloud/hooks/stackdriver.py

@@ -18,6 +18,7 @@
 """This module contains Google Cloud Stackdriver operators."""
 from __future__ import annotations
 
+import contextlib
 import json
 from typing import TYPE_CHECKING, Any, Sequence
 
@@ -295,15 +296,13 @@ def upsert_alert(
                     policy.notification_channels[i] = new_channel
 
             if policy.name in existing_policies:
-                try:
+                with contextlib.suppress(InvalidArgument):
                     policy_client.update_alert_policy(
                         request={"alert_policy": policy},
                         retry=retry,
                         timeout=timeout,
                         metadata=metadata,
                     )
-                except InvalidArgument:
-                    pass
             else:
                 policy.name = None
                 for condition in policy.conditions: