Last active
January 25, 2021 17:38
-
-
Save iht/ada9d99e2d1c5e129c5d0f5bab8cff1c to your computer and use it in GitHub Desktop.
Set Dataflow options programatically
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
def run_pipeline(argv): | |
opts: PipelineOptions = PipelineOptions(argv) | |
gcloud_opts: GoogleCloudOptions = opts.view_as(GoogleCloudOptions) | |
gcloud_opts.enable_streaming_engine = True | |
gcloud_opts.job_name = "Overwrite the name of your job" | |
... |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment