Manny Brar
Can anyone point me in the right direction witht his error?
(ERROR:apache_beam.runners.direct.executor:Exception at bundle <apache_beam.runners.direct.bundle_factory._Bundle object at 0x7f71fa86d4c8>, due to an exception. Traceback (most recent call last):)
Also seeing the following error:
AttributeError: ‘SubscriberClient’ object has no attribute ‘transport’
1 Answers
Tim Berry
Hi there
I’m sorry but I’m not able to replicate this error, the lab is running fine for me.
Did you update the code and set your own PROJECT_ID in both tweeper.py and pipeline.py?
Can you show me the full command line you are using to run pipeline.py with the DataflowRunner option?
Thanks
Naomijohnson
This is the code that causes the error: python pipeline.py –streaming
Also getting this error. Can someone please point us to the right place?