[ https://issues.apache.org/jira/browse/BEAM-3670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16358781#comment-16358781 ]
cclauss commented on BEAM-3670: ------------------------------- The last message talks about **line 1453** but the text it is showing is from the next function on **line 1456**. [https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/core.py#L1453-L1456] Are we sure that it is using to code that is currently on **master**? Also Python 2.7.5 is raising a bunch of requests/urllib3 warnings that are fixed in 2.7.9+... Current Python 2 is 2.7.14. > DirectRunner: TypeError: 'KeyedWorkItem' object is not iterable > --------------------------------------------------------------- > > Key: BEAM-3670 > URL: https://issues.apache.org/jira/browse/BEAM-3670 > Project: Beam > Issue Type: Bug > Components: sdk-py-core > Reporter: Ahmet Altay > Assignee: Charles Chen > Priority: Major > > 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'] -- This message was sent by Atlassian JIRA (v7.6.3#76005)