Merge pull request #10149 [BEAM-8739] Consistently use with Pipeline(...) syntax
diff --git a/sdks/python/apache_beam/examples/wordcount_xlang.py b/sdks/python/apache_beam/examples/wordcount_xlang.py
index 4d75579..b8353bb 100644
--- a/sdks/python/apache_beam/examples/wordcount_xlang.py
+++ b/sdks/python/apache_beam/examples/wordcount_xlang.py
@@ -27,6 +27,7 @@
import subprocess
import grpc
+from past.builtins import unicode
import apache_beam as beam
from apache_beam.io import ReadFromText
@@ -64,7 +65,7 @@
counts = (lines
| 'split' >> (beam.ParDo(WordExtractingDoFn())
- .with_output_types(bytes))
+ .with_output_types(unicode))
| 'count' >> beam.ExternalTransform(
'beam:transforms:xlang:count', None, EXPANSION_SERVICE_ADDR))
