[
https://issues.apache.org/jira/browse/AIRFLOW-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033234#comment-17033234
]
ASF subversion and git services commented on AIRFLOW-6761:
----------------------------------------------------------
Commit 9282185e6624e64bb7f17447f81c1b2d1bb4d56d in airflow's branch
refs/heads/master from Van-Duyet Le
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=9282185 ]
[AIRFLOW-6761] Fix WorkGroup param in AWSAthenaHook (#7386)
Unknown parameter in input: "Workgroup", must be one of: QueryString,
ClientRequestToken, QueryExecutionContext, ResultConfiguration, WorkGroup
> Wrong "Workgroup" param in aws_athena_hook.py
> ---------------------------------------------
>
> Key: AIRFLOW-6761
> URL: https://issues.apache.org/jira/browse/AIRFLOW-6761
> Project: Apache Airflow
> Issue Type: Bug
> Components: hooks
> Affects Versions: 1.10.8, 1.10.9
> Reporter: Van-Duyet Le
> Assignee: Van-Duyet Le
> Priority: Major
>
> Maybe a typo error at run_query function in aws_athena_hook.py
> {code:java}
> Unknown parameter in input: "Workgroup", must be one of: QueryString,
> ClientRequestToken, QueryExecutionContext, ResultConfiguration, WorkGroup
> Traceback (most recent call last):
> File
> "/usr/local/lib/python3.7/site-packages/airflow/models/taskinstance.py", line
> 966, in _run_raw_task
> result = task_copy.execute(context=context)
> File "/opt/airflow/dags/operators/athena_result_operator.py", line 14, in
> execute
> query_execution_id = super().execute(context)
> File
> "/usr/local/lib/python3.7/site-packages/airflow/contrib/operators/aws_athena_operator.py",
> line 85, in execute
> self.workgroup)
> File
> "/usr/local/lib/python3.7/site-packages/airflow/contrib/hooks/aws_athena_hook.py",
> line 77, in run_query
> Workgroup=workgroup)
> File "/usr/local/lib/python3.7/site-packages/botocore/client.py", line 276,
> in _api_call
> return self._make_api_call(operation_name, kwargs)
> File "/usr/local/lib/python3.7/site-packages/botocore/client.py", line 559,
> in _make_api_call
> api_params, operation_model, context=request_context)
> File "/usr/local/lib/python3.7/site-packages/botocore/client.py", line 607,
> in _convert_to_request_dict
> api_params, operation_model)
> File "/usr/local/lib/python3.7/site-packages/botocore/validate.py", line
> 297, in serialize_to_request
> raise ParamValidationError(report=report.generate_report())
> botocore.exceptions.ParamValidationError: Parameter validation failed:
> Unknown parameter in input: "Workgroup", must be one of: QueryString,
> ClientRequestToken, QueryExecutionContext, ResultConfiguration, WorkGroup
> {code}
> According to [boto3's
> docs|https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/athena.html#Athena.Client.start_query_execution],
> it's should be {{WorkGroup}}
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
