You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Tomasz Urbaszek (Jira)" <ji...@apache.org> on 2020/02/09 15:17:00 UTC

[jira] [Resolved] (AIRFLOW-6761) Wrong "Workgroup" param in aws_athena_hook.py

     [ https://issues.apache.org/jira/browse/AIRFLOW-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Tomasz Urbaszek resolved AIRFLOW-6761.
--------------------------------------
    Fix Version/s: 1.10.10
       Resolution: Fixed

> 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
>             Fix For: 1.10.10
>
>
> 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)