damianr13 commented on issue #28716: URL: https://github.com/apache/beam/issues/28716#issuecomment-1761252020
@tvalentyn Thanks for your reply. Based on what you said I added some breakpoints and I discovered that this is where the decision to not use FnApi runner is taken: https://github.com/apache/beam/blob/05861613f484a6159c21796006c52d8da5e10b2a/sdks/python/apache_beam/runners/direct/direct_runner.py#L111C18-L111C18 This happens while it checks `_GroupIntoBatchesDoFn`. Here is a screenshot of the timer data I took in my IDE:  I could investigate further and come up with a PR maybe, but I will need a few pointers: - Why is the check for "REAL_TIME" here in the first place? - What does it mean for a ParDo to be "REAL_TIME"? -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
