Paulius Dambrauskas created AIRFLOW-1030:
--------------------------------------------

             Summary: HttpHook error when creating HttpSensor
                 Key: AIRFLOW-1030
                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1030
             Project: Apache Airflow
          Issue Type: Bug
          Components: core
    Affects Versions: Airflow 1.8
         Environment: python3
            Reporter: Paulius Dambrauskas
            Assignee: Paulius Dambrauskas


Task:
{code}
sensor = HttpSensor(
    task_id='http_sensor_check',
    http_conn_id='http_default',
    endpoint='',
    params={},
    poke_interval=5,
    dag=dag
)
{code}

Exception
{code}
Traceback (most recent call last):
  File 
"/usr/local/lib/python3.5/dist-packages/airflow-1.9.0.dev0+apache.incubating-py3.5.egg/airflow/models.py",
 line 268, in process_file
    m = imp.load_source(mod_name, filepath)
  File "/usr/lib/python3.5/imp.py", line 172, in load_source
    module = _load(spec)
  File "<frozen importlib._bootstrap>", line 693, in _load
  File "<frozen importlib._bootstrap>", line 673, in _load_unlocked
  File "<frozen importlib._bootstrap_external>", line 665, in exec_module
  File "<frozen importlib._bootstrap>", line 222, in _call_with_frames_removed
  File "/home/paulius/airflow/dags/cpg_4.py", line 43, in <module>
    dag=dag)
  File 
"/usr/local/lib/python3.5/dist-packages/airflow-1.9.0.dev0+apache.incubating-py3.5.egg/airflow/utils/decorators.py",
 line 86, in wrapper
    result = func(*args, **kwargs)
  File 
"/usr/local/lib/python3.5/dist-packages/airflow-1.9.0.dev0+apache.incubating-py3.5.egg/airflow/operators/sensors.py",
 line 663, in __init__
    self.hook = hooks.http_hook.HttpHook(method='GET', 
http_conn_id=http_conn_id)
  File 
"/usr/local/lib/python3.5/dist-packages/airflow-1.9.0.dev0+apache.incubating-py3.5.egg/airflow/utils/helpers.py",
 line 436, in __getattr__
    raise AttributeError
AttributeError
{code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to