Hi all, I have written a short design doc on adding the ability to specify python callables as kwargs to transforms within the Beam YAML SDK. This would solve the issue that some transforms require a callable input parameter (i.e. beam.Map expects a callable fn parameter), despite YAML not having a concept of callables directly.
https://docs.google.com/document/d/1Zvrl-rxzAWKejHi5F1eaXoLNDzc_Q_-kiE7Grvh2qBA/edit Take a look and feel free to leave suggestions in the comments. Thanks, Jeff