I believe this should be fully working. I'm not familiar with PyBeam though. Is the execution mechanism the same as running a regular Beam pipeline ? Also, note that for multi-language, you need to use a portable Beam runner.
+Daniel Collins <dpcoll...@google.com> who implemented this. Thanks, Cham On Thu, Aug 4, 2022 at 11:24 AM Austin Bennett <whatwouldausti...@gmail.com> wrote: > Hi Users/Devs, > > Drew, copied, reported having troubles with PubSub Lite: > > "we just weren’t able to get PubSub Lite working with PyBeam. It’s been a > few weeks since we last tried, but we were just trying to use > `apache_beam.io.gcp.pubsublite.ReadFromPubSubLite` (here > <https://beam.apache.org/releases/pydoc/current/apache_beam.io.gcp.pubsublite.html> > ) in PyBeam and couldn’t get it to import so we just gave up. From the > looks of the repo we couldn’t tell if it was ever actually fully > implemented and published" > > I haven't used myself, and figured others might be able to comment/share > at least if any have had success using and/or at least whether fully > tested/implemented IO ( whether available via cross-language or 'native' > python ). > > Please share any thoughts here. > > Cheers, > Austin > >