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)