[
https://issues.apache.org/jira/browse/AIRFLOW-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16970238#comment-16970238
]
ASF GitHub Bot commented on AIRFLOW-5875:
-----------------------------------------
potiuk commented on pull request #6525: [AIRFLOW-5875] Fix typo in
example_qubole_operator.py
URL: https://github.com/apache/airflow/pull/6525
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> 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
>
> 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)
