This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 1848010b3bb Fix MyPy failing on mssql Cursor (#48686)
1848010b3bb is described below

commit 1848010b3bb810b5eda7fb836d617e9bbcf29748
Author: Jarek Potiuk <[email protected]>
AuthorDate: Wed Apr 2 15:23:23 2025 +0200

    Fix MyPy failing on mssql Cursor (#48686)
---
 .../hive/src/airflow/providers/apache/hive/transfers/mssql_to_hive.py   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/providers/apache/hive/src/airflow/providers/apache/hive/transfers/mssql_to_hive.py
 
b/providers/apache/hive/src/airflow/providers/apache/hive/transfers/mssql_to_hive.py
index 458efbf3251..88f000dc3eb 100644
--- 
a/providers/apache/hive/src/airflow/providers/apache/hive/transfers/mssql_to_hive.py
+++ 
b/providers/apache/hive/src/airflow/providers/apache/hive/transfers/mssql_to_hive.py
@@ -122,7 +122,7 @@ class MsSqlToHiveOperator(BaseOperator):
                     for col_count, field in enumerate(cursor.description, 
start=1):
                         col_position = f"Column{col_count}"
                         field_dict[col_position if field[0] == "" else 
field[0]] = self.type_map(field[1])
-                    csv_writer.writerows(cursor)
+                    csv_writer.writerows(cursor)  # type:ignore[arg-type]
                     tmp_file.flush()
 
             hive = HiveCliHook(hive_cli_conn_id=self.hive_cli_conn_id, 
auth=self.hive_auth)

Reply via email to