robertwb commented on code in PR #25935:
URL: https://github.com/apache/beam/pull/25935#discussion_r1145196005
##########
sdks/python/apache_beam/yaml/yaml_transform.py:
##########
@@ -377,6 +378,18 @@ def pipeline_as_composite(spec):
return dict(spec, name=None, type='composite')
+def normalize_source_sink(spec):
Review Comment:
What if there are multiple sources and/or sinks? Should these take a list?
(In chains, for sources we could flatten, for sinks we could write to all.) Or
does this get too magical? One can always just put additional ones in the
transforms list. (Or let the source itself be a type: Composite with a manual
flatten in it.) Any thoughts here?
--
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]
