[AIRFLOW-5195] Move GCP Dataflow to core (#5799)

This commit moves GCP Dataflow from contrib to core. For more information check AIP-21.
apache · Aug 17, 2019 · b3acb3d · b3acb3d
1 parent e071bd7
commit b3acb3d
Show file tree

Hide file tree

Showing 9 changed files with 1,007 additions and 942 deletions.
diff --git a/airflow/contrib/hooks/gcp_dataflow_hook.py b/airflow/contrib/hooks/gcp_dataflow_hook.py
diff --git a/airflow/contrib/operators/dataflow_operator.py b/airflow/contrib/operators/dataflow_operator.py
diff --git a/airflow/contrib/utils/mlengine_operator_utils.py b/airflow/contrib/utils/mlengine_operator_utils.py
@@ -23,7 +23,7 @@
 
 from airflow.contrib.hooks.gcs_hook import GoogleCloudStorageHook
 from airflow.contrib.operators.mlengine_operator import MLEngineBatchPredictionOperator
-from airflow.contrib.operators.dataflow_operator import DataFlowPythonOperator
+from airflow.gcp.operators.dataflow import DataFlowPythonOperator
 from airflow.exceptions import AirflowException
 from airflow.operators.python_operator import PythonOperator
 from urllib.parse import urlsplit