Uploaded image for project: 'Apache Airflow'
  1. Apache Airflow
  2. AIRFLOW-5484

PigCliHook has incorrect named parameter

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 1.10.5
    • Fix Version/s: 1.10.6
    • Component/s: hooks
    • Labels:

      Description

      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

      elif self.conn_type == 'pig_cli':
          from airflow.hooks.pig_hook import PigCliHook
          return PigCliHook(pig_conn_id=self.conn_id) 

      airflow/hooks/pig_hook.py:38

      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 

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                jghoman Jakob Homan
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: