Hi Reuven,

You are right. "Async" for this implementation is very misleading. For
python async_dofn, it's only asynchronous if *use_asyncio=True*.

For use_asyncio=False mode and the matching Java implementation, we offload
execution to a background thread pool which seems like a multi-threaded
approach rather than a strictly async based one. Would renaming it to
something like *ConcurrentDoFn* or *ConcurrentDoFnWrapper* work better?

Thanks,
Tejas Iyer

>

Reply via email to