airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (Jira)" <j...@apache.org>
Subject [jira] [Commented] (AIRFLOW-5875) The example qubole operator has a typo that causes import error
Date Fri, 08 Nov 2019 14:34:00 GMT

    [ 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:
users@infra.apache.org


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

Mime
View raw message