guan404ming commented on code in PR #54195:
URL: https://github.com/apache/airflow/pull/54195#discussion_r2261175624
##########
providers/amazon/src/airflow/providers/amazon/aws/transfers/sql_to_s3.py:
##########
@@ -128,14 +134,45 @@ def __init__(
self.aws_conn_id = aws_conn_id
self.verify = verify
self.replace = replace
- self.pd_kwargs = pd_kwargs or {}
self.parameters = parameters
- self.read_pd_kwargs = read_pd_kwargs or {}
self.max_rows_per_file = max_rows_per_file
self.groupby_kwargs = groupby_kwargs or {}
self.sql_hook_params = sql_hook_params
+ self.df_type = df_type
+ if read_pd_kwargs is not None and read_kwargs is not None:
+ raise AirflowException(
+ "Cannot specify both 'read_kwargs' and 'read_pd_kwargs'. Use
'read_kwargs' instead."
+ )
Review Comment:
Make sense to me and I've updated. Please take another look, thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
