@apply_defaults
def __init__(self, *, query: str, s3_bucket: str, s3_key: str, mysql_conn_id: str='mysql_default', aws_conn_id: str='aws_default', verify: Optional[Union[(bool, str)]]=None, pd_csv_kwargs: Optional[dict]=None, index: bool=False, header: bool=False, **kwargs) -> None:
    super().__init__(**kwargs)
    self.query = query
    self.s3_bucket = s3_bucket
    self.s3_key = s3_key
    self.mysql_conn_id = mysql_conn_id
    self.aws_conn_id = aws_conn_id
    self.verify = verify
    self.pd_csv_kwargs = (pd_csv_kwargs or {})
    if ('path_or_buf' in self.pd_csv_kwargs):
        raise AirflowException('The argument path_or_buf is not allowed, please remove it')
    if ('index' not in self.pd_csv_kwargs):
        self.pd_csv_kwargs['index'] = index
    if ('header' not in self.pd_csv_kwargs):
        self.pd_csv_kwargs['header'] = header
@apply_defaults
def __init__(self, *, query: str, s3_bucket: str, s3_key: str, mysql_conn_id: str='mysql_default', aws_conn_id: str='aws_default', verify: Optional[Union[(bool, str)]]=None, pd_csv_kwargs: Optional[dict]=None, index: bool=False, header: bool=False, **kwargs) -> None:
    super().__init__(**kwargs)
    self.query = query
    self.s3_bucket = s3_bucket
    self.s3_key = s3_key
    self.mysql_conn_id = mysql_conn_id
    self.aws_conn_id = aws_conn_id
    self.verify = verify
    self.pd_csv_kwargs = (pd_csv_kwargs or {})
    if ('path_or_buf' in self.pd_csv_kwargs):
        raise AirflowException('The argument path_or_buf is not allowed, please remove it')
    if ('index' not in self.pd_csv_kwargs):
        self.pd_csv_kwargs['index'] = index
    if ('header' not in self.pd_csv_kwargs):
        self.pd_csv_kwargs['header'] = header