The apache beam pipeline (python) I'm currently working on contains a transformation which runs a docker container. While that works well during local testing w
I have created a new dataproc cluster with a specific environment.yaml. Here is the command that I have used to create that cluster: gcloud dataproc clusters cr