Hello, We are planning to use Beam Python SDK (with Dataflow) to export entities in the datastore to bigquery. We are using an in -house ORM library for datastore and it is async. I did a bit search to see whether it is possible to use async with Beam Python SDK but did not find it anywhere (neither in jira issues nor the documentations). Can anyone give some information about it ?
Thanks,
