Search code examples
google-cloud-platformairflowgoogle-cloud-dataflow

Airlfow DAG DataflowTemplatedJobStartOperator with Google Provided Template GCS_Text_to_Cloud_PubSub


Basically, I simply want to use the existing Google template GCS_Text_to_Cloud_PubSub for using it in my DAG for DataflowTemplatedJobStartOperator. I searched a lot but couldn't find a way to download the template and store under my GCS. So that I can point DataflowTemplatedJobStartOperator to it.


Solution

  • All the templates should be under gs://dataflow-templates/latest