[ 
https://issues.apache.org/jira/browse/AIRFLOW-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16970239#comment-16970239
 ] 

ASF subversion and git services commented on AIRFLOW-5875:
----------------------------------------------------------

Commit 33ddcd9ef7b0c7c1e888e4aad93a641022571a9f in airflow's branch 
refs/heads/master from Jarek Potiuk
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=33ddcd9 ]

[AIRFLOW-5875] Fix typo in example_qubole_operator.py (#6525)



> 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)

Reply via email to