You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/01/25 19:51:39 UTC
incubator-airflow git commit: [AIRFLOW-2031] Add missing gcp_conn_id
in the example in DataFlow docstrings
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 <ka...@gmail.com>
Authored: Thu Jan 25 20:51:22 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
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