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’
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
Can you show me the full command line you are using to run
pipeline.py with the
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?