We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fd384c4 commit b69db51Copy full SHA for b69db51
airflow/contrib/operators/dataflow_operator.py
@@ -90,7 +90,7 @@ class DataFlowJavaOperator(BaseOperator):
90
91
.. code-block:: python
92
93
- t1 = DataFlowOperation(
+ t1 = DataFlowJavaOperator(
94
task_id='datapflow_example',
95
jar='{{var.value.gcp_dataflow_base}}pipeline/build/libs/pipeline-example-1.0.jar',
96
options={
0 commit comments