[jira] [Updated] (AIRFLOW-5484) PigCliHook has incorrect named parameter

["Ash Berlin-Taylor (Jira)" <ji...@apache.org>]

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

Ash Berlin-Taylor updated AIRFLOW-5484:
---------------------------------------
    Affects Version/s:     (was: 1.10.6)
                       1.10.5

> PigCliHook has incorrect named parameter
> ----------------------------------------
>
>                 Key: AIRFLOW-5484
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-5484
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: hooks
>    Affects Versions: 1.10.5
>            Reporter: Jakob Homan
>            Priority: Minor
>              Labels: ccoss2019, newbie
>
> When building the connection hook, we try to assign a variable named `pig_conn_id`.  However, this doesn't exist, the correct name is `pig_cli_conn_id`.  This will cause the correct config to not be picked up.
> airflow/models/connection.py:212
> {code:java}
> elif self.conn_type == 'pig_cli':
>     from airflow.hooks.pig_hook import PigCliHook
>     return PigCliHook(pig_conn_id=self.conn_id) {code}
> airflow/hooks/pig_hook.py:38
> {code:java}
> def __init__(
>         self,
>         pig_cli_conn_id="pig_cli_default"):
>     conn = self.get_connection(pig_cli_conn_id)
>     self.pig_properties = conn.extra_dejson.get('pig_properties', '')
>     self.conn = conn {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)