tvalentyn commented on issue #36201: URL: https://github.com/apache/beam/issues/36201#issuecomment-3850491964
Thanks @nikitagrover19 There was a related effort in https://github.com/apache/beam/pull/31608 . Reading through that work, I think this issue is more nuanced. I believe _PubSubWriteDoFn might be used by Beam Direct runner only, but not Dataflow Runner, so making changes to that code would have a limited effect for non-trivial usages of Beam. To support this functionality with the Dataflow runner, we might have to support an option like `--enable_custom_pubsub_sink` in Python SDK as well or have Dataflow support https://issuetracker.google.com/issues/200955424 . cc'ing @sjvanrossum @ahmedabu98 @scwhittle who worked on https://github.com/apache/beam/pull/31608 and can correct me. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
