Hello,
I am getting the following warnings:
[2018-08-13 20:23:51,224] {base_task_runner.py:98} INFO - Subtask: /usr/local/lib/python2.7/site-packages/airflow/utils/helpers.py:351: DeprecationWarning: Importing HttpHook directly from <module 'airflow.hooks' from '/usr/local/lib/python2.7/site-packages/airflow/hooks/__init__.pyc'> has been deprecated. Please import from '<module 'airflow.hooks' from '/usr/local/lib/python2.7/site-packages/airflow/hooks/__init__.pyc'>.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0.
[2018-08-13 20:23:51,228] {base_task_runner.py:98} INFO - Subtask: DeprecationWarning)
[2018-08-13 20:23:51,887] {base_task_runner.py:98} INFO - Subtask: /usr/local/lib/python2.7/site-packages/airflow/utils/helpers.py:351: DeprecationWarning: Importing PythonOperator directly from <module 'airflow.operators' from '/usr/local/lib/python2.7/site-packages/airflow/operators/__init__.pyc'> has been deprecated. Please import from '<module 'airflow.operators' from '/usr/local/lib/python2.7/site-packages/airflow/operators/__init__.pyc'>.[operator_module]' instead. Support for direct imports will be dropped entirely in Airflow 2.0.
[2018-08-13 20:23:51,893] {base_task_runner.py:98} INFO - Subtask: DeprecationWarning)
Here are my import statements:
from airflow.hooks import HttpHook
from airflow.operators import PythonOperator
I understand from the error I am suppose to be importing from somewhere else but it is not clear to me where.
Anyone know the correct way? All the examples I see online use the above import statements
Thanks,
--