robertwb commented on code in PR #25935:
URL: https://github.com/apache/beam/pull/25935#discussion_r1145466560
##########
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:
Yes. Chain is restricted to linear chains (where the advantage is that the
wiring of inputs to outputs can be inferred by the order, rather than having to
be explicitly named and called out).
I'm leaning towards the single source/sink as well, with an allof (TBD),
which is what is implemented here. Also, these are not yet set in stone.
--
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]
