[beam] branch master updated: [BEAM-6454] Fix dict_values error in DataflowRunner

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

altay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 0e89b1b  [BEAM-6454] Fix dict_values error in DataflowRunner
     new 9f6db0e  Merge pull request #7538 from markflyhigh/py3-df-dict-error
0e89b1b is described below

commit 0e89b1bb29d63bb3855805eaf858aa88f681ae31
Author: Mark Liu <ma...@google.com>
AuthorDate: Wed Jan 16 10:11:07 2019 -0800

    [BEAM-6454] Fix dict_values error in DataflowRunner
---
 sdks/python/apache_beam/runners/dataflow/dataflow_runner.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index e76f1bc..447b964 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -458,7 +458,7 @@ class DataflowRunner(PipelineRunner):
       window_coder = None
     from apache_beam.runners.dataflow.internal import apiclient
     use_fnapi = apiclient._use_fnapi(
-        transform_node.outputs.values()[0].pipeline._options)
+        list(transform_node.outputs.values())[0].pipeline._options)
     return self._get_typehint_based_encoding(element_type, window_coder,
                                              use_fnapi)