[BEAM-3670] DirectRunner: TypeError: 'KeyedWorkItem' object is not iterable

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Cannot Reproduce
• Fix Version/s: Not applicable
• Component/s: sdk-py-core
• Assignee: Charles Chen
• Reporter: Ahmet Altay
• Created: 08/Feb/18 23:17
• Updated: 24/Jul/20 20:12
• Resolved: 27/Jun/18 00:12

Description

I see the following error in a pre-commit test with no code changes:

https://builds.apache.org/job/beam_PreCommit_Python_MavenInstall/2661/org.apache.beam$beam-sdks-python/console

 
root: ERROR: Exception at bundle <apache_beam.runners.direct.bundle_factory._Bundle object at 0x7fa5f5cdafc8>, due to an exception.
Traceback (most recent call last):
File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/executor.py", line 305, in call
side_input_values)
File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/executor.py", line 338, in attempt_call
evaluator.process_element(value)
File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/runners/direct/transform_evaluator.py", line 560, in process_element
self.runner.process(element)
File "apache_beam/runners/common.py", line 468, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:13915)
def process(self, windowed_value):
File "apache_beam/runners/common.py", line 474, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:13719)
self._reraise_augmented(exn)
File "apache_beam/runners/common.py", line 515, in apache_beam.runners.common.DoFnRunner._reraise_augmented (apache_beam/runners/common.c:14934)
raise new_exn, None, original_traceback
File "apache_beam/runners/common.py", line 472, in apache_beam.runners.common.DoFnRunner.process (apache_beam/runners/common.c:13632)
self.do_fn_invoker.invoke_process(windowed_value)
File "apache_beam/runners/common.py", line 270, in apache_beam.runners.common.SimpleInvoker.invoke_process (apache_beam/runners/common.c:9084)
windowed_value, self.process_method(windowed_value.value))
File "/home/jenkins/jenkins-slave/workspace/beam_PreCommit_Python_MavenInstall/src/sdks/python/apache_beam/transforms/core.py", line 1453, in process
k, vs = element
TypeError: 'KeyedWorkItem' object is not iterable [while running 'assert_that/Group/GroupByKey/GroupByWindow']