TanuSharma2511 commented on PR #34716: URL: https://github.com/apache/beam/pull/34716#issuecomment-2906453729
@hjtran I tried to check the code further but it seems like it is not easy to apply check in PTransform.__ror__ because there are root transforms which expects PBegin as input. The next difficulty is to identify the differentiation of source transform from other transforms. One possible identification may be source transform has impulse() as sub transform but I am not sure if this is correct and applicable for all root transforms. Other difficulty is how it will behave with multi language pipeline... If you have any approach in mind, please share so that I can check on that. -- 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: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org