You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Anonymous (Jira)" <ji...@apache.org> on 2023/04/13 11:10:00 UTC
[jira] [Updated] (BEAM-14351) Example 'JsonCoder' object has no attribute 'to_type_hint'
[ https://issues.apache.org/jira/browse/BEAM-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anonymous updated BEAM-14351:
-----------------------------
Status: Triage Needed (was: Resolved)
> Example 'JsonCoder' object has no attribute 'to_type_hint'
> ----------------------------------------------------------
>
> Key: BEAM-14351
> URL: https://issues.apache.org/jira/browse/BEAM-14351
> Project: Beam
> Issue Type: Bug
> Components: examples-python
> Reporter: Andrew Pilloud
> Assignee: Robert Bradshaw
> Priority: P1
> Fix For: 2.39.0
>
> Time Spent: 1h
> Remaining Estimate: 0h
>
> This test wasn't running due to BEAM-14336, I'm not sure it ever ran successfully. It is a hard failure in beam_PostCommit_Python_Examples_Dataflow apache_beam.examples.cookbook.coders_it_test.CodersIT.test_coders_output_files_on_small_input:
> https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Dataflow/293/testReport/junit/apache_beam.examples.cookbook.coders_it_test/CodersIT/test_coders_output_files_on_small_input/
> {code}
> self = <apache_beam.examples.cookbook.coders_it_test.CodersIT testMethod=test_coders_output_files_on_small_input>
> @pytest.mark.no_xdist
> @pytest.mark.examples_postcommit
> def test_coders_output_files_on_small_input(self):
> test_pipeline = TestPipeline(is_integration_test=True)
> # Setup the files with expected content.
> OUTPUT_FILE_DIR = \
> 'gs://temp-storage-for-end-to-end-tests/py-it-cloud/output'
> output = '/'.join([OUTPUT_FILE_DIR, str(uuid.uuid4()), 'result'])
> INPUT_FILE_DIR = \
> 'gs://temp-storage-for-end-to-end-tests/py-it-cloud/input'
> input = '/'.join([INPUT_FILE_DIR, str(uuid.uuid4()), 'input.txt'])
> create_content_input_file(
> input, '\n'.join(map(json.dumps, self.SAMPLE_RECORDS)))
> extra_opts = {'input': input, 'output': output}
> > coders.run(test_pipeline.get_full_options_as_args(**extra_opts))
> apache_beam/examples/cookbook/coders_it_test.py:93:
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> apache_beam/examples/cookbook/coders.py:87: in run
> p
> apache_beam/transforms/ptransform.py:1092: in __ror__
> return self.transform.__ror__(pvalueish, self.label)
> apache_beam/transforms/ptransform.py:614: in __ror__
> result = p.apply(self, pvalueish, label)
> apache_beam/pipeline.py:662: in apply
> return self.apply(transform, pvalueish)
> apache_beam/pipeline.py:708: in apply
> pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
> apache_beam/runners/dataflow/dataflow_runner.py:141: in apply
> return super().apply(transform, input, options)
> apache_beam/runners/runner.py:185: in apply
> return m(transform, input, options)
> apache_beam/runners/runner.py:215: in apply_PTransform
> return transform.expand(input)
> apache_beam/io/textio.py:690: in expand
> self._source.output_type_hint())
> _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
> self = <apache_beam.io.textio._TextSource object at 0x7fef4d8071c0>
> def output_type_hint(self):
> try:
> > return self._coder.to_type_hint()
> E AttributeError: 'JsonCoder' object has no attribute 'to_type_hint'
> apache_beam/io/textio.py:409: AttributeError
> {code}
> cc: [~tvalentyn]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)