Remove pylint messages control instructions (#28555)

Taragolis · web-flow · commit 034039beb256 · 2022-12-24T03:01:56.000+04:00
diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
@@ -1540,7 +1540,7 @@ def _run_finished_callback(
             for callback in callbacks:
                 try:
                     callback(context)
-                except Exception:  # pylint: disable=broad-except
+                except Exception:
                     callback_name = qualname(callback).split(".")[-1]
                     self.log.exception(
                         f"Error when executing {callback_name} callback"  # type: ignore[attr-defined]
diff --git a/airflow/providers/google/cloud/sensors/dataproc.py b/airflow/providers/google/cloud/sensors/dataproc.py
@@ -18,7 +18,6 @@
 """This module contains a Dataproc Job sensor."""
 from __future__ import annotations
 
-# pylint: disable=C0302
 import time
 from typing import TYPE_CHECKING, Sequence
 
diff --git a/airflow/sensors/external_task.py b/airflow/sensors/external_task.py
@@ -319,7 +319,7 @@ def get_count(self, dttm_filter, session, states) -> int:
     def _count_query(self, model, session, states, dttm_filter) -> Query:
         query = session.query(func.count()).filter(
             model.dag_id == self.external_dag_id,
-            model.state.in_(states),  # pylint: disable=no-member
+            model.state.in_(states),
             model.execution_date.in_(dttm_filter),
         )
         return query
diff --git a/airflow/utils/timeout.py b/airflow/utils/timeout.py
@@ -38,7 +38,7 @@ def __init__(self, seconds=1, error_message="Timeout"):
         self.seconds = seconds
         self.error_message = error_message + ", PID: " + str(os.getpid())
 
-    def handle_timeout(self, *args):  # pylint: disable=unused-argument
+    def handle_timeout(self, *args):
         """Logs information and raises AirflowTaskTimeout."""
         self.log.error("Process timed out, PID: %s", str(os.getpid()))
         raise AirflowTaskTimeout(self.error_message)
diff --git a/tests/providers/google/cloud/operators/test_cloud_build.py b/tests/providers/google/cloud/operators/test_cloud_build.py
@@ -52,9 +52,6 @@
 from airflow.utils.timezone import datetime
 from airflow.utils.types import DagRunType
 
-# pylint: disable=R0904, C0111
-
-
 GCP_CONN_ID = "google_cloud_default"
 PROJECT_ID = "cloud-build-project"
 CLOUD_BUILD_HOOK_PATH = "airflow.providers.google.cloud.operators.cloud_build.CloudBuildHook"

Original file line number	Diff line number	Diff line change
`@@ -319,7 +319,7 @@ def get_count(self, dttm_filter, session, states) -> int:`
`319`	`319`	`def _count_query(self, model, session, states, dttm_filter) -> Query:`
`320`	`320`	`query = session.query(func.count()).filter(`
`321`	`321`	`model.dag_id == self.external_dag_id,`
`322`		`- model.state.in_(states), # pylint: disable=no-member`
	`322`	`+ model.state.in_(states),`
`323`	`323`	`model.execution_date.in_(dttm_filter),`
`324`	`324`	`)`
`325`	`325`	`return query`