I guess there are multiple options. The easiest one would be converting the async method to a sync method or creating a wrapper method for doing so.
Also, the following stackoverflow post introduces another two options you may find useful. - asynchronous API calls in apache beam - https://stackoverflow.com/questions/72842846/asynchronous-api-calls-in-apache-beam On Mon, 26 Aug 2024 at 01:40, Sofia’s World <mmistr...@gmail.com> wrote: > Not sure...I think I'll do a sample and post it on the list .. > Thanks > Marco > > On Sun, 25 Aug 2024, 14:46 XQ Hu via user, <user@beam.apache.org> wrote: > >> >> https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/transforms/Wait.html >> >> Is this something you are looking for? >> >> On Sun, Aug 25, 2024 at 6:21 AM Sofia’s World <mmistr...@gmail.com> >> wrote: >> >>> HI all >>> i want to write a pipeline where, as part of one of the steps, i will >>> need to use >>> an await call ,such as this one >>> >>> await fetcher.fetch_data(params, self.credentials) >>> >>> is Beam equipped for that? >>> >>> Does anyone have a sample to pass me for reference? >>> >>> Kind regards >>> Marco >>> >>> >>>
