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