title: How do you drain a dataflow job through the gcloud api?
body: <p>Is it possible to drain a running dataflow job through the the gcloud api? Specifically is there a python implementation of this, or documentation of the request structure so that it can be implemented? It would be nice to be able to automate draining, and reconfiguring dataflow streaming jobs without the use of the cli.</p>