diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index bdfa386a8e5e9..ed0271374de71 100644 --- 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 index 9df525c7151a9..9d422a70f169d 100644 --- 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 index e9573a0671237..e1eec6d192684 100644 --- 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 index 818cb2f69163c..06c4ba1de7694 100644 --- 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 index 0ec514267ed93..096de51ced148 100644 --- 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"