diff --git a/providers/apache/spark/src/airflow/providers/apache/spark/hooks/spark_sql.py b/providers/apache/spark/src/airflow/providers/apache/spark/hooks/spark_sql.py index e810bc1f9ec38..119e265dc0492 100644 --- a/providers/apache/spark/src/airflow/providers/apache/spark/hooks/spark_sql.py +++ b/providers/apache/spark/src/airflow/providers/apache/spark/hooks/spark_sql.py @@ -204,7 +204,7 @@ def run_query(self, cmd: str = "", **kwargs: Any) -> None: spark_sql_cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, universal_newlines=True, **kwargs ) - for line in iter(self._sp.stdout): # type: ignore + for line in iter(self._sp.stdout): self.log.info(line) returncode = self._sp.wait()