[
https://issues.apache.org/jira/browse/AIRFLOW-5875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jarek Potiuk updated AIRFLOW-5875:
----------------------------------
Description:
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}
> 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)
