From 92f83c87bc94a687639d6b05ca8a8e1af9887848 Mon Sep 17 00:00:00 2001 From: David Cavazos Date: Tue, 15 Sep 2020 15:22:33 -0700 Subject: [PATCH] Update commands to GA (#4658) --- dataflow/flex-templates/streaming_beam/README.md | 10 ++++++---- dataflow/flex-templates/streaming_beam/metadata.json | 6 +++--- 2 files changed, 9 insertions(+), 7 deletions(-) diff --git a/dataflow/flex-templates/streaming_beam/README.md b/dataflow/flex-templates/streaming_beam/README.md index 316fb5ea1923..298e08d4cce5 100644 --- a/dataflow/flex-templates/streaming_beam/README.md +++ b/dataflow/flex-templates/streaming_beam/README.md @@ -155,7 +155,7 @@ and is used to run a new Dataflow job. export TEMPLATE_PATH="gs://$BUCKET/samples/dataflow/templates/streaming-beam.json" # Build the Flex Template. -gcloud beta dataflow flex-template build $TEMPLATE_PATH \ +gcloud dataflow flex-template build $TEMPLATE_PATH \ --image "$TEMPLATE_IMAGE" \ --sdk-language "PYTHON" \ --metadata-file "metadata.json" @@ -173,9 +173,11 @@ required by the pipeline. ```sh # Run the Flex Template. -gcloud beta dataflow flex-template run "streaming-beam-`date +%Y%m%d-%H%M%S`" \ - --template-file-gcs-location "$TEMPLATE_PATH" \ - --parameters "input_subscription=$SUBSCRIPTION,output_table=$PROJECT:$DATASET.$TABLE" +gcloud dataflow flex-template run "streaming-beam-`date +%Y%m%d-%H%M%S`" \ + --template-file-gcs-location "$TEMPLATE_PATH" \ + --parameters input_subscription="$SUBSCRIPTION" \ + --parameters output_table="$PROJECT:$DATASET.$TABLE" \ + --region "$REGION" ``` Check the results in BigQuery by running the following query: diff --git a/dataflow/flex-templates/streaming_beam/metadata.json b/dataflow/flex-templates/streaming_beam/metadata.json index 029a505d2b94..fa61ba3b971c 100644 --- a/dataflow/flex-templates/streaming_beam/metadata.json +++ b/dataflow/flex-templates/streaming_beam/metadata.json @@ -5,7 +5,7 @@ { "name": "input_subscription", "label": "Input PubSub subscription.", - "help_text": "Name of the input PubSub subscription to consume from.", + "helpText": "Name of the input PubSub subscription to consume from.", "regexes": [ "[a-zA-Z][-_.~+%a-zA-Z0-9]{2,}" ] @@ -13,8 +13,8 @@ { "name": "output_table", "label": "BigQuery output table name.", - "help_text": "Name of the BigQuery output table name.", - "is_optional": true, + "helpText": "Name of the BigQuery output table name.", + "isOptional": true, "regexes": [ "[^:]+:[^.]+[.].+" ]