Repository: incubator-airflow Updated Branches: refs/heads/master bfbdeca65 -> 3dbfdafd7
[AIRFLOW-2031] Add missing gcp_conn_id in the example in DataFlow docstrings - Added `gcp_conn_id` parameter in the examples provided in docstrings for DataFlow operators. Closes #2973 from kaxil/patch-3 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/3dbfdafd Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/3dbfdafd Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/3dbfdafd Branch: refs/heads/master Commit: 3dbfdafd7a5f41f7b9d0a0a7ef1872385a477a54 Parents: bfbdeca Author: Kaxil Naik <[email protected]> Authored: Thu Jan 25 20:51:22 2018 +0100 Committer: Fokko Driesprong <[email protected]> Committed: Thu Jan 25 20:51:22 2018 +0100 ---------------------------------------------------------------------- airflow/contrib/operators/dataflow_operator.py | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/3dbfdafd/airflow/contrib/operators/dataflow_operator.py ---------------------------------------------------------------------- diff --git a/airflow/contrib/operators/dataflow_operator.py b/airflow/contrib/operators/dataflow_operator.py index 5c34678..b8c9431 100644 --- a/airflow/contrib/operators/dataflow_operator.py +++ b/airflow/contrib/operators/dataflow_operator.py @@ -56,6 +56,7 @@ class DataFlowJavaOperator(BaseOperator): 'partitionType': 'DAY', 'labels': {'foo' : 'bar'} }, + gcp_conn_id='gcp-airflow-service-account', dag=my-dag) ``` @@ -166,6 +167,7 @@ class DataflowTemplateOperator(BaseOperator): 'inputFile': "gs://bucket/input/my_input.txt", 'outputFile': "gs://bucket/output/my_output.txt" }, + gcp_conn_id='gcp-airflow-service-account', dag=my-dag) ``` ``template`` ``dataflow_default_options`` and ``parameters`` are templated so you can
