I have a requirement to orchestrate a dataflow python job using cloud composer DAG.
Did anyone came across this requirement or know how to implement, pls help me by guiding to the article. Thanks before hand.
This documentation [1] should help you. Also find the discussion thread here [2].
[1] https://cloud.google.com/composer/docs/how-to/using/using-dataflow-template-operator#python
[2] https://groups.google.com/g/cloud-composer-discuss/c/1uL9_1u3J0A