diff --git a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
index b90844e44dd3..5028cb89a892 100644
--- a/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
+++ b/sdks/python/apache_beam/runners/dataflow/dataflow_runner.py
@@ -32,6 +32,7 @@
 
 from future.moves.urllib.parse import quote
 from future.moves.urllib.parse import unquote
+from future.utils import iteritems
 
 import apache_beam as beam
 from apache_beam import coders