Skip to content

Commit 4f2492d

Browse files
Upstream flex template update (#4677) (#3246)
* Upstream flex template update * Remove unused var Signed-off-by: Modular Magician <[email protected]>
1 parent 0360fea commit 4f2492d

File tree

4 files changed

+5
-6
lines changed

4 files changed

+5
-6
lines changed

.changelog/4677.txt

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
```release-note:enhancement
2+
dataflow: enabled updates for `google_dataflow_flex_template_job`
3+
```

google-beta/resource_dataflow_flex_template_job_test.go

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,6 @@ data "google_storage_bucket_object" "flex_template" {
158158
name = "latest/flex/Streaming_Data_Generator"
159159
bucket = "dataflow-templates"
160160
}
161-
162161
resource "google_dataflow_flex_template_job" "job" {
163162
name = "%s"
164163
container_spec_gcs_path = "gs://${data.google_storage_bucket_object.flex_template.bucket}/${data.google_storage_bucket_object.flex_template.name}"
@@ -179,17 +178,14 @@ resource "google_service_account" "dataflow-sa" {
179178
account_id = "%s"
180179
display_name = "DataFlow Service Account"
181180
}
182-
183181
resource "google_project_iam_member" "dataflow-worker" {
184182
role = "roles/dataflow.worker"
185183
member = "serviceAccount:${google_service_account.dataflow-sa.email}"
186184
}
187-
188185
data "google_storage_bucket_object" "flex_template" {
189186
name = "latest/flex/Streaming_Data_Generator"
190187
bucket = "dataflow-templates"
191188
}
192-
193189
resource "google_dataflow_flex_template_job" "job" {
194190
name = "%s"
195191
container_spec_gcs_path = "gs://${data.google_storage_bucket_object.flex_template.bucket}/${data.google_storage_bucket_object.flex_template.name}"

google-beta/resource_dataflow_job.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -583,7 +583,6 @@ func resourceDataflowJobIterateMapHasChange(mapKey string, d *schema.ResourceDat
583583
func resourceDataflowJobIsVirtualUpdate(d *schema.ResourceData, resourceSchema map[string]*schema.Schema) bool {
584584
// on_delete is the only virtual field
585585
if d.HasChange("on_delete") {
586-
// Check if other fields have changes, which would require an actual update request
587586
for field := range resourceSchema {
588587
if field == "on_delete" {
589588
continue

google-beta/resource_dataproc_cluster_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,9 @@ import (
1313
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
1414
"github.com/hashicorp/terraform-plugin-sdk/v2/terraform"
1515

16-
dataproc "google.golang.org/api/dataproc/v1beta2"
1716
"google.golang.org/api/googleapi"
17+
18+
dataproc "google.golang.org/api/dataproc/v1beta2"
1819
)
1920

2021
func TestDataprocExtractInitTimeout(t *testing.T) {

0 commit comments

Comments
 (0)