Selin Gungor created BEAM-11318:
-----------------------------------
Summary: AttributeError: 'SubscriberClient' object has no
attribute 'transport' error while reading from input subscription with
ReadFromPubSub
Key: BEAM-11318
URL: https://issues.apache.org/jira/browse/BEAM-11318
Project: Beam
Issue Type: Bug
Components: beam-model
Affects Versions: 2.25.0
Environment: MacOs 10.15.7 and Ubuntu 18, 20
Reporter: Selin Gungor
When I read from the input-subcroption with beam.io.ReadFromPubSub. The error
below is thrown.
{quote} AttributeError: 'SubscriberClient' object has no attribute 'transport'
{quote}
Code
{{pipeline_options = PipelineOptions()}}
{{pipeline_options.view_as(StandardOptions).streaming = True}}
{{pipeline = beam.Pipeline(options=pipeline_options)}}
{{messages = (pipeline |
beam.io.ReadFromPubSub(subscription=input_subscription).with_output_types(bytes))}}
{{def printattr(element):}}
{{ print(element.attributes)}}
{{lines = messages | 'printattr' >> beam.Map(printattr)}}
{{result = pipeline.run()}}
{{result.wait_until_finish()}}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
