aaltay commented on pull request #12185: URL: https://github.com/apache/beam/pull/12185#issuecomment-655766565
I initially thought this change would only impact fnapi runner and local execution. I assume the intention is to apply the optimization to all portable runners. I noticed that portable runner depends on fnapi_runner (https://github.com/apache/beam/blob/2dddc0c9d60315fd212a90bc2ac39fd2bcc8bf63/sdks/python/apache_beam/runners/portability/portable_runner.py#L51). So maybe this optimization applies to all portable executions. @robertwb - Do you know why portable_runner depends on fnapi_runner? ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org