[jira] [Resolved] (AIRFLOW-5875) The example qubole operator has a typo that causes import error

["Jarek Potiuk (Jira)" <ji...@apache.org>]

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

Jarek Potiuk resolved AIRFLOW-5875.
-----------------------------------
    Fix Version/s: 2.0.0
       Resolution: Fixed

> The example qubole operator has a typo that causes import error
> ---------------------------------------------------------------
>
>                 Key: AIRFLOW-5875
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-5875
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: operators
>    Affects Versions: 2.0.0
>            Reporter: Jarek Potiuk
>            Priority: Major
>             Fix For: 2.0.0
>
>
> ERROR - Failed to import: /root/airflow/dags/repo/airflow/contrib/example_dags/example_qubole_operator.py
> Traceback (most recent call last):
>  File "/opt/airflow/airflow/models/dagbag.py", line 238, in process_file
>  m = imp.load_source(mod_name, filepath)
>  File "/usr/local/lib/python3.7/imp.py", line 171, in load_source
>  module = _load(spec)
>  File "<frozen importlib._bootstrap>", line 696, in _load
>  File "<frozen importlib._bootstrap>", line 677, in _load_unlocked
>  File "<frozen importlib._bootstrap_external>", line 728, in exec_module
>  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
>  File "/root/airflow/dags/repo/airflow/contrib/example_dags/example_qubole_operator.py", line 94, in <module>
>  trigger_rule="all_done"
>  File "/opt/airflow/airflow/utils/decorators.py", line 92, in wrapper
>  result = func(*args, **kwargs)
>  File "/opt/airflow/airflow/contrib/operators/qubole_operator.py", line 174, in __init__
>  super().__init__(*args, **filtered_base_kwargs)
>  File "/opt/airflow/airflow/utils/decorators.py", line 92, in wrapper
>  result = func(*args, **kwargs)
>  File "/opt/airflow/airflow/models/baseoperator.py", line 330, in __init__
>  c=self.__class__.__name__, a=args, k=kwargs, t=task_id),
> airflow.exceptions.AirflowException: Invalid arguments were passed to QuboleOperator (task_id: hive_s3_location). Invalid arguments were:
> *args: ()
> **kwargs: \{'notfiy': True}



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