addressed code review observations and minor doc changes

Uddipaan Hazarika · Uddipaan Hazarika · commit d65e74bc5800 · 2025-03-18T18:57:13.000+05:30
diff --git a/docs/resources/oracle_dsource.md b/docs/resources/oracle_dsource.md
@@ -4,7 +4,7 @@ In Delphix terminology, a dSource is an internal, read-only database copy that t
 
 A dSource is created and managed by the Delphix Continuous Data Engine and syncs with your chosen source database. 
 
-The Oracle dSource resource allows Terraform to create and delete Oracle dSources. This specifically enables the `apply`, `import`, and `destroy` Terraform commands. 
+The Oracle dSource resource allows Terraform to create and delete Oracle dSources via Terraform automation. This specifically enables the `apply`, `import`, and `destroy` Terraform commands. 
 
 Updating existing dSource resource parameters via the `apply` command is supported for the parameters listed below.  
 
@@ -82,10 +82,11 @@ The following arguments enable the user to control how the first snapshot should
 * `double_sync` - True if two SnapSyncs should be performed in immediate succession to reduce the number of logs required to provision the snapshot. This may significantly reduce the time necessary to provision from a snapshot. 
 * `do_not_resume` - Indicates if a fresh SnapSync must be started regardless of whether it was possible to resume the current SnapSync. If true, we will not resume; instead, we will ignore previous progress and back up all datafiles even if they have already been completed from the last failed SnapSync. This does not force a full backup; if an incremental was in progress this will start a new incremental snapshot. 
 * `skip_wait_for_snapshot_creation` - By default this resource will wait for a snapshot to be created post-dSource creation. This ensures a snapshot is available during the VDB provisioning. This behavior can be skipped by setting this parameter to `true`. 
-* `wait_time` - This value controls how long the resource will wait for the initial snapshot to be successfully ingested by Delphix. By default, the value is 0, meaning it does not wait for the snapshot to be created. If a synchronous behavior, specifies a value that is slightly longer than the average ingestion time. This argument was introduced in Delphix provider v3.2.1.  
+* `wait_time` - This value controls how long the resource will wait for the initial snapshot to be successfully ingested by Delphix. By default, the value is 0, meaning it does not wait for the snapshot to be created. When using this parameter, it is recommended to use a value that is slightly longer than the average ingestion time. This argument was introduced in Delphix provider v3.2.1.  
 
 This parameter can be ignored if 'skip_wait_for_snapshot_creation' is set to `true`. 
 
+Note: In DCT v2025.1, waiting for SnapSync to complete is default functionality. Therefore, these the arguments `skip_wait_for_snapshot_creation` and `wait_time` are ignored. In future versions of the provider, we will look at re-implementing the skip SnapSync behavior. 
 
 ### Password and Password Vault Management 
 
diff --git a/internal/provider/resource_appdata_dsource.go b/internal/provider/resource_appdata_dsource.go
@@ -469,9 +469,9 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m
 		return diags
 	}
 
-	d.SetId(*apiRes.DsourceId)
+	d.SetId(apiRes.GetDsourceId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with dSource creation. Error: "+job_err)
 	}
@@ -481,10 +481,10 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m
 	rollback_on_failure := d.Get("rollback_on_failure").(bool)
 
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")
 		if rollback_on_failure {
 			if job_res == Failed {
-				res := isSnapSyncFailure(*apiRes.Job.Id, ctx, client)
+				res := isSnapSyncFailure(apiRes.Job.GetId(), ctx, client)
 				if res {
 					deleteDiags := resourceDsourceDelete(ctx, d, meta)
 					if deleteDiags.HasError() {
@@ -500,7 +500,7 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m
 				return readDiags
 			}
 		}
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 
 	PollSnapshotStatus(d, ctx, client)
@@ -605,13 +605,13 @@ func resourceDsourceDelete(ctx context.Context, d *schema.ResourceData, meta int
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, *res.Id, job_err)
+		return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, res.GetId(), job_err)
 	}
 
 	_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {
diff --git a/internal/provider/resource_database_postgresql.go b/internal/provider/resource_database_postgresql.go
@@ -157,9 +157,9 @@ func resourceDatabasePostgressqlCreate(ctx context.Context, d *schema.ResourceDa
 		return diags
 	}
 
-	d.SetId(*apiRes.SourceId)
+	d.SetId(apiRes.GetSourceId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with Source creation. Error: "+job_err)
 	}
@@ -168,8 +168,8 @@ func resourceDatabasePostgressqlCreate(ctx context.Context, d *schema.ResourceDa
 
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
 		d.SetId("")
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id)
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId())
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 
 	readDiags := resourceDatabasePostgressqlRead(ctx, d, meta)
@@ -300,13 +300,13 @@ func resourceDatabasePostgressqlUpdate(ctx context.Context, d *schema.ResourceDa
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Source Update Job Polling failed but continuing with update. Error :"+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] Source-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] Source-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)
 	}
 
 	return diags
@@ -323,13 +323,13 @@ func resourceDatabasePostgressqlDelete(ctx context.Context, d *schema.ResourceDa
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+" Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] Source-Delete %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] Source-Delete %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)
 	}
 
 	_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {
diff --git a/internal/provider/resource_environment.go b/internal/provider/resource_environment.go
@@ -393,15 +393,15 @@ func resourceEnvironmentCreate(ctx context.Context, d *schema.ResourceData, meta
 	}
 
 	d.SetId(apiRes.GetEnvironmentId())
-	job_status, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with env creation. Error: "+job_err)
 	}
 
 	if isJobTerminalFailure(job_status) {
 		d.SetId("")
-		return diag.Errorf("[NOT OK] Env-Create %s. JobId: %s / Error: %s", job_status, *apiRes.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] Env-Create %s. JobId: %s / Error: %s", job_status, apiRes.Job.GetId(), job_err)
 	}
 	// Get environment info and store state.
 	readDiags := resourceEnvironmentRead(ctx, d, meta)
@@ -463,12 +463,12 @@ func resourceEnvironmentDelete(ctx context.Context, d *schema.ResourceData, meta
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with env deletion. Error: "+job_err)
 	}
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] Env-Delete %s. JobId: %s / Error: %s", job_status, *apiRes.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] Env-Delete %s. JobId: %s / Error: %s", job_status, apiRes.Job.GetId(), job_err)
 	}
 	_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {
 		return client.EnvironmentsAPI.GetEnvironmentById(ctx, envId).Execute()
diff --git a/internal/provider/resource_oracle_dsource.go b/internal/provider/resource_oracle_dsource.go
@@ -786,9 +786,9 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me
 		return diags
 	}
 
-	d.SetId(*apiRes.DsourceId)
+	d.SetId(apiRes.GetDsourceId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with dSource creation. Error: "+job_err)
 	}
@@ -798,10 +798,10 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me
 	rollback_on_failure := d.Get("rollback_on_failure").(bool)
 
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")
 		if rollback_on_failure {
 			if job_res == Failed {
-				res := isSnapSyncFailure(*apiRes.Job.Id, ctx, client)
+				res := isSnapSyncFailure(apiRes.Job.GetId(), ctx, client)
 				if res {
 					deleteDiags := resourceOracleDsourceDelete(ctx, d, meta)
 					if deleteDiags.HasError() {
@@ -817,7 +817,7 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me
 				return readDiags
 			}
 		}
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 
 	PollSnapshotStatus(d, ctx, client)
@@ -1037,13 +1037,13 @@ func resourceOracleDsourceUpdate(ctx context.Context, d *schema.ResourceData, me
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Dsource Update Job Polling failed but continuing with update. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] Dsource-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] Dsource-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)
 	}
 
 	if d.HasChanges(
@@ -1092,13 +1092,13 @@ func resourceOracleDsourceDelete(ctx context.Context, d *schema.ResourceData, me
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, *res.Id, job_err)
+		return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, res.GetId(), job_err)
 	}
 
 	_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {
diff --git a/internal/provider/resource_vdb.go b/internal/provider/resource_vdb.go
@@ -996,16 +996,16 @@ func helper_provision_by_snapshot(ctx context.Context, d *schema.ResourceData, m
 		return diags
 	}
 
-	d.SetId(*apiRes.VdbId)
+	d.SetId(apiRes.GetVdbId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 
 	readDiags := resourceVdbRead(ctx, d, meta)
@@ -1244,16 +1244,16 @@ func helper_provision_by_timestamp(ctx context.Context, d *schema.ResourceData,
 		return diags
 	}
 
-	d.SetId(*apiRes.VdbId)
+	d.SetId(apiRes.GetVdbId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)
 	if job_res == "FAILED" {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+*apiRes.Job.Id+" Failed!")
-		return diag.Errorf("[NOT OK] Job %s Failed with error %s", *apiRes.Job.Id, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+apiRes.Job.GetId()+" Failed!")
+		return diag.Errorf("[NOT OK] Job %s Failed with error %s", apiRes.Job.GetId(), job_err)
 	}
 
 	readDiags := resourceVdbRead(ctx, d, meta)
@@ -1477,16 +1477,16 @@ func helper_provision_by_bookmark(ctx context.Context, d *schema.ResourceData, m
 		return diags
 	}
 
-	d.SetId(*apiRes.VdbId)
+	d.SetId(apiRes.GetVdbId())
 
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+*apiRes.Job.Id+"!")
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+apiRes.Job.GetId()+"!")
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 
 	readDiags := resourceVdbRead(ctx, d, meta)
@@ -1911,13 +1911,13 @@ func resourceVdbUpdate(ctx context.Context, d *schema.ResourceData, meta interfa
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"VDB Update Job Polling failed but continuing with update. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] VDB-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] VDB-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)
 	}
 
 	if d.HasChanges(
@@ -1970,13 +1970,13 @@ func resourceVdbDelete(ctx context.Context, d *schema.ResourceData, meta interfa
 		return diags
 	}
 
-	job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)
+	job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error : "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)
 	if isJobTerminalFailure(job_status) {
-		return diag.Errorf("[NOT OK] VDB-Delete %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)
+		return diag.Errorf("[NOT OK] VDB-Delete %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)
 	}
 
 	_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {
diff --git a/internal/provider/utility.go b/internal/provider/utility.go
@@ -287,15 +287,15 @@ func disableVDB(ctx context.Context, client *dctapi.APIClient, vdbId string) dia
 	if diags := apiErrorResponseHelper(ctx, apiRes, httpRes, err); diags != nil {
 		return diags
 	}
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"VDB disable Job Polling failed. Error: "+job_err)
 		//return here
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 	return nil
 }
@@ -307,14 +307,14 @@ func enableVDB(ctx context.Context, client *dctapi.APIClient, vdbId string) diag
 	if diags := apiErrorResponseHelper(ctx, apiRes, httpRes, err); diags != nil {
 		return diags
 	}
-	job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)
+	job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)
 	if job_err != "" {
 		tflog.Warn(ctx, DLPX+WARN+"VDB enable Job Polling failed. Error: "+job_err)
 	}
 	tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)
 	if job_res == Failed || job_res == Canceled || job_res == Abandoned {
-		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")
-		return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)
+		tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")
+		return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)
 	}
 	return nil
 }

Original file line number	Diff line number	Diff line change
`@@ -469,9 +469,9 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m`
`469`	`469`	`return diags`
`470`	`470`	`}`
`471`	`471`
`472`		`- d.SetId(*apiRes.DsourceId)`
	`472`	`+ d.SetId(apiRes.GetDsourceId())`
`473`	`473`
`474`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`474`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`475`	`475`	`if job_err != "" {`
`476`	`476`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with dSource creation. Error: "+job_err)`
`477`	`477`	`}`
`@@ -481,10 +481,10 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m`
`481`	`481`	`rollback_on_failure := d.Get("rollback_on_failure").(bool)`
`482`	`482`
`483`	`483`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`484`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")`
	`484`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")`
`485`	`485`	`if rollback_on_failure {`
`486`	`486`	`if job_res == Failed {`
`487`		`- res := isSnapSyncFailure(*apiRes.Job.Id, ctx, client)`
	`487`	`+ res := isSnapSyncFailure(apiRes.Job.GetId(), ctx, client)`
`488`	`488`	`if res {`
`489`	`489`	`deleteDiags := resourceDsourceDelete(ctx, d, meta)`
`490`	`490`	`if deleteDiags.HasError() {`
`@@ -500,7 +500,7 @@ func resourceAppdataDsourceCreate(ctx context.Context, d *schema.ResourceData, m`
`500`	`500`	`return readDiags`
`501`	`501`	`}`
`502`	`502`	`}`
`503`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`503`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`504`	`504`	`}`
`505`	`505`
`506`	`506`	`PollSnapshotStatus(d, ctx, client)`
`@@ -605,13 +605,13 @@ func resourceDsourceDelete(ctx context.Context, d *schema.ResourceData, meta int`
`605`	`605`	`return diags`
`606`	`606`	`}`
`607`	`607`
`608`		`- job_status, job_err := PollJobStatus(*res.Id, ctx, client)`
	`608`	`+ job_status, job_err := PollJobStatus(res.GetId(), ctx, client)`
`609`	`609`	`if job_err != "" {`
`610`	`610`	`tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)`
`611`	`611`	`}`
`612`	`612`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`613`	`613`	`if isJobTerminalFailure(job_status) {`
`614`		`- return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, *res.Id, job_err)`
	`614`	`+ return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, res.GetId(), job_err)`
`615`	`615`	`}`
`616`	`616`
`617`	`617`	`_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {`
Original file line number	Diff line number	Diff line change
`@@ -157,9 +157,9 @@ func resourceDatabasePostgressqlCreate(ctx context.Context, d *schema.ResourceDa`
`157`	`157`	`return diags`
`158`	`158`	`}`
`159`	`159`
`160`		`- d.SetId(*apiRes.SourceId)`
	`160`	`+ d.SetId(apiRes.GetSourceId())`
`161`	`161`
`162`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`162`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`163`	`163`	`if job_err != "" {`
`164`	`164`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with Source creation. Error: "+job_err)`
`165`	`165`	`}`
`@@ -168,8 +168,8 @@ func resourceDatabasePostgressqlCreate(ctx context.Context, d *schema.ResourceDa`
`168`	`168`
`169`	`169`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`170`	`170`	`d.SetId("")`
`171`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id)`
`172`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`171`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId())`
	`172`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`173`	`173`	`}`
`174`	`174`
`175`	`175`	`readDiags := resourceDatabasePostgressqlRead(ctx, d, meta)`
`@@ -300,13 +300,13 @@ func resourceDatabasePostgressqlUpdate(ctx context.Context, d *schema.ResourceDa`
`300`	`300`	`return diags`
`301`	`301`	`}`
`302`	`302`
`303`		`- job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)`
	`303`	`+ job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)`
`304`	`304`	`if job_err != "" {`
`305`	`305`	`tflog.Warn(ctx, DLPX+WARN+"Source Update Job Polling failed but continuing with update. Error :"+job_err)`
`306`	`306`	`}`
`307`	`307`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`308`	`308`	`if isJobTerminalFailure(job_status) {`
`309`		`- return diag.Errorf("[NOT OK] Source-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)`
	`309`	`+ return diag.Errorf("[NOT OK] Source-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)`
`310`	`310`	`}`
`311`	`311`
`312`	`312`	`return diags`
`@@ -323,13 +323,13 @@ func resourceDatabasePostgressqlDelete(ctx context.Context, d *schema.ResourceDa`
`323`	`323`	`return diags`
`324`	`324`	`}`
`325`	`325`
`326`		`- job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)`
	`326`	`+ job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)`
`327`	`327`	`if job_err != "" {`
`328`	`328`	`tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)`
`329`	`329`	`}`
`330`	`330`	`tflog.Info(ctx, DLPX+INFO+" Job result is "+job_status)`
`331`	`331`	`if isJobTerminalFailure(job_status) {`
`332`		`- return diag.Errorf("[NOT OK] Source-Delete %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)`
	`332`	`+ return diag.Errorf("[NOT OK] Source-Delete %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)`
`333`	`333`	`}`
`334`	`334`
`335`	`335`	`_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {`
Original file line number	Diff line number	Diff line change
`@@ -393,15 +393,15 @@ func resourceEnvironmentCreate(ctx context.Context, d *schema.ResourceData, meta`
`393`	`393`	`}`
`394`	`394`
`395`	`395`	`d.SetId(apiRes.GetEnvironmentId())`
`396`		`- job_status, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`396`	`+ job_status, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`397`	`397`
`398`	`398`	`if job_err != "" {`
`399`	`399`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with env creation. Error: "+job_err)`
`400`	`400`	`}`
`401`	`401`
`402`	`402`	`if isJobTerminalFailure(job_status) {`
`403`	`403`	`d.SetId("")`
`404`		`- return diag.Errorf("[NOT OK] Env-Create %s. JobId: %s / Error: %s", job_status, *apiRes.Job.Id, job_err)`
	`404`	`+ return diag.Errorf("[NOT OK] Env-Create %s. JobId: %s / Error: %s", job_status, apiRes.Job.GetId(), job_err)`
`405`	`405`	`}`
`406`	`406`	`// Get environment info and store state.`
`407`	`407`	`readDiags := resourceEnvironmentRead(ctx, d, meta)`
`@@ -463,12 +463,12 @@ func resourceEnvironmentDelete(ctx context.Context, d *schema.ResourceData, meta`
`463`	`463`	`return diags`
`464`	`464`	`}`
`465`	`465`
`466`		`- job_status, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`466`	`+ job_status, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`467`	`467`	`if job_err != "" {`
`468`	`468`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with env deletion. Error: "+job_err)`
`469`	`469`	`}`
`470`	`470`	`if isJobTerminalFailure(job_status) {`
`471`		`- return diag.Errorf("[NOT OK] Env-Delete %s. JobId: %s / Error: %s", job_status, *apiRes.Job.Id, job_err)`
	`471`	`+ return diag.Errorf("[NOT OK] Env-Delete %s. JobId: %s / Error: %s", job_status, apiRes.Job.GetId(), job_err)`
`472`	`472`	`}`
`473`	`473`	`_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {`
`474`	`474`	`return client.EnvironmentsAPI.GetEnvironmentById(ctx, envId).Execute()`
Original file line number	Diff line number	Diff line change
`@@ -786,9 +786,9 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me`
`786`	`786`	`return diags`
`787`	`787`	`}`
`788`	`788`
`789`		`- d.SetId(*apiRes.DsourceId)`
	`789`	`+ d.SetId(apiRes.GetDsourceId())`
`790`	`790`
`791`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`791`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`792`	`792`	`if job_err != "" {`
`793`	`793`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with dSource creation. Error: "+job_err)`
`794`	`794`	`}`
`@@ -798,10 +798,10 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me`
`798`	`798`	`rollback_on_failure := d.Get("rollback_on_failure").(bool)`
`799`	`799`
`800`	`800`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`801`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")`
	`801`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")`
`802`	`802`	`if rollback_on_failure {`
`803`	`803`	`if job_res == Failed {`
`804`		`- res := isSnapSyncFailure(*apiRes.Job.Id, ctx, client)`
	`804`	`+ res := isSnapSyncFailure(apiRes.Job.GetId(), ctx, client)`
`805`	`805`	`if res {`
`806`	`806`	`deleteDiags := resourceOracleDsourceDelete(ctx, d, meta)`
`807`	`807`	`if deleteDiags.HasError() {`
`@@ -817,7 +817,7 @@ func resourceOracleDsourceCreate(ctx context.Context, d *schema.ResourceData, me`
`817`	`817`	`return readDiags`
`818`	`818`	`}`
`819`	`819`	`}`
`820`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`820`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`821`	`821`	`}`
`822`	`822`
`823`	`823`	`PollSnapshotStatus(d, ctx, client)`
`@@ -1037,13 +1037,13 @@ func resourceOracleDsourceUpdate(ctx context.Context, d *schema.ResourceData, me`
`1037`	`1037`	`return diags`
`1038`	`1038`	`}`
`1039`	`1039`
`1040`		`- job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)`
	`1040`	`+ job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)`
`1041`	`1041`	`if job_err != "" {`
`1042`	`1042`	`tflog.Warn(ctx, DLPX+WARN+"Dsource Update Job Polling failed but continuing with update. Error: "+job_err)`
`1043`	`1043`	`}`
`1044`	`1044`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`1045`	`1045`	`if isJobTerminalFailure(job_status) {`
`1046`		`- return diag.Errorf("[NOT OK] Dsource-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)`
	`1046`	`+ return diag.Errorf("[NOT OK] Dsource-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)`
`1047`	`1047`	`}`
`1048`	`1048`
`1049`	`1049`	`if d.HasChanges(`
`@@ -1092,13 +1092,13 @@ func resourceOracleDsourceDelete(ctx context.Context, d *schema.ResourceData, me`
`1092`	`1092`	`return diags`
`1093`	`1093`	`}`
`1094`	`1094`
`1095`		`- job_status, job_err := PollJobStatus(*res.Id, ctx, client)`
	`1095`	`+ job_status, job_err := PollJobStatus(res.GetId(), ctx, client)`
`1096`	`1096`	`if job_err != "" {`
`1097`	`1097`	`tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error :"+job_err)`
`1098`	`1098`	`}`
`1099`	`1099`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`1100`	`1100`	`if isJobTerminalFailure(job_status) {`
`1101`		`- return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, *res.Id, job_err)`
	`1101`	`+ return diag.Errorf("[NOT OK] dSource-Delete %s. JobId: %s / Error: %s", job_status, res.GetId(), job_err)`
`1102`	`1102`	`}`
`1103`	`1103`
`1104`	`1104`	`_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {`
Original file line number	Diff line number	Diff line change
`@@ -996,16 +996,16 @@ func helper_provision_by_snapshot(ctx context.Context, d *schema.ResourceData, m`
`996`	`996`	`return diags`
`997`	`997`	`}`
`998`	`998`
`999`		`- d.SetId(*apiRes.VdbId)`
	`999`	`+ d.SetId(apiRes.GetVdbId())`
`1000`	`1000`
`1001`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`1001`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`1002`	`1002`	`if job_err != "" {`
`1003`	`1003`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)`
`1004`	`1004`	`}`
`1005`	`1005`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)`
`1006`	`1006`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`1007`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")`
`1008`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`1007`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")`
	`1008`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`1009`	`1009`	`}`
`1010`	`1010`
`1011`	`1011`	`readDiags := resourceVdbRead(ctx, d, meta)`
`@@ -1244,16 +1244,16 @@ func helper_provision_by_timestamp(ctx context.Context, d *schema.ResourceData,`
`1244`	`1244`	`return diags`
`1245`	`1245`	`}`
`1246`	`1246`
`1247`		`- d.SetId(*apiRes.VdbId)`
	`1247`	`+ d.SetId(apiRes.GetVdbId())`
`1248`	`1248`
`1249`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`1249`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`1250`	`1250`	`if job_err != "" {`
`1251`	`1251`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)`
`1252`	`1252`	`}`
`1253`	`1253`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)`
`1254`	`1254`	`if job_res == "FAILED" {`
`1255`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+*apiRes.Job.Id+" Failed!")`
`1256`		`- return diag.Errorf("[NOT OK] Job %s Failed with error %s", *apiRes.Job.Id, job_err)`
	`1255`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+apiRes.Job.GetId()+" Failed!")`
	`1256`	`+ return diag.Errorf("[NOT OK] Job %s Failed with error %s", apiRes.Job.GetId(), job_err)`
`1257`	`1257`	`}`
`1258`	`1258`
`1259`	`1259`	`readDiags := resourceVdbRead(ctx, d, meta)`
`@@ -1477,16 +1477,16 @@ func helper_provision_by_bookmark(ctx context.Context, d *schema.ResourceData, m`
`1477`	`1477`	`return diags`
`1478`	`1478`	`}`
`1479`	`1479`
`1480`		`- d.SetId(*apiRes.VdbId)`
	`1480`	`+ d.SetId(apiRes.GetVdbId())`
`1481`	`1481`
`1482`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`1482`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`1483`	`1483`	`if job_err != "" {`
`1484`	`1484`	`tflog.Error(ctx, DLPX+ERROR+"Job Polling failed but continuing with provisioning. Error: "+job_err)`
`1485`	`1485`	`}`
`1486`	`1486`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)`
`1487`	`1487`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`1488`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+*apiRes.Job.Id+"!")`
`1489`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`1488`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+apiRes.Job.GetId()+"!")`
	`1489`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`1490`	`1490`	`}`
`1491`	`1491`
`1492`	`1492`	`readDiags := resourceVdbRead(ctx, d, meta)`
`@@ -1911,13 +1911,13 @@ func resourceVdbUpdate(ctx context.Context, d *schema.ResourceData, meta interfa`
`1911`	`1911`	`return diags`
`1912`	`1912`	`}`
`1913`	`1913`
`1914`		`- job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)`
	`1914`	`+ job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)`
`1915`	`1915`	`if job_err != "" {`
`1916`	`1916`	`tflog.Warn(ctx, DLPX+WARN+"VDB Update Job Polling failed but continuing with update. Error: "+job_err)`
`1917`	`1917`	`}`
`1918`	`1918`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`1919`	`1919`	`if isJobTerminalFailure(job_status) {`
`1920`		`- return diag.Errorf("[NOT OK] VDB-Update %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)`
	`1920`	`+ return diag.Errorf("[NOT OK] VDB-Update %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)`
`1921`	`1921`	`}`
`1922`	`1922`
`1923`	`1923`	`if d.HasChanges(`
`@@ -1970,13 +1970,13 @@ func resourceVdbDelete(ctx context.Context, d *schema.ResourceData, meta interfa`
`1970`	`1970`	`return diags`
`1971`	`1971`	`}`
`1972`	`1972`
`1973`		`- job_status, job_err := PollJobStatus(*res.Job.Id, ctx, client)`
	`1973`	`+ job_status, job_err := PollJobStatus(res.Job.GetId(), ctx, client)`
`1974`	`1974`	`if job_err != "" {`
`1975`	`1975`	`tflog.Warn(ctx, DLPX+WARN+"Job Polling failed but continuing with deletion. Error : "+job_err)`
`1976`	`1976`	`}`
`1977`	`1977`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_status)`
`1978`	`1978`	`if isJobTerminalFailure(job_status) {`
`1979`		`- return diag.Errorf("[NOT OK] VDB-Delete %s. JobId: %s / Error: %s", job_status, *res.Job.Id, job_err)`
	`1979`	`+ return diag.Errorf("[NOT OK] VDB-Delete %s. JobId: %s / Error: %s", job_status, res.Job.GetId(), job_err)`
`1980`	`1980`	`}`
`1981`	`1981`
`1982`	`1982`	`_, diags := PollForObjectDeletion(ctx, func() (interface{}, *http.Response, error) {`
Original file line number	Diff line number	Diff line change
`@@ -287,15 +287,15 @@ func disableVDB(ctx context.Context, client *dctapi.APIClient, vdbId string) dia`
`287`	`287`	`if diags := apiErrorResponseHelper(ctx, apiRes, httpRes, err); diags != nil {`
`288`	`288`	`return diags`
`289`	`289`	`}`
`290`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`290`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`291`	`291`	`if job_err != "" {`
`292`	`292`	`tflog.Warn(ctx, DLPX+WARN+"VDB disable Job Polling failed. Error: "+job_err)`
`293`	`293`	`//return here`
`294`	`294`	`}`
`295`	`295`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)`
`296`	`296`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`297`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")`
`298`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`297`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")`
	`298`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`299`	`299`	`}`
`300`	`300`	`return nil`
`301`	`301`	`}`
`@@ -307,14 +307,14 @@ func enableVDB(ctx context.Context, client *dctapi.APIClient, vdbId string) diag`
`307`	`307`	`if diags := apiErrorResponseHelper(ctx, apiRes, httpRes, err); diags != nil {`
`308`	`308`	`return diags`
`309`	`309`	`}`
`310`		`- job_res, job_err := PollJobStatus(*apiRes.Job.Id, ctx, client)`
	`310`	`+ job_res, job_err := PollJobStatus(apiRes.Job.GetId(), ctx, client)`
`311`	`311`	`if job_err != "" {`
`312`	`312`	`tflog.Warn(ctx, DLPX+WARN+"VDB enable Job Polling failed. Error: "+job_err)`
`313`	`313`	`}`
`314`	`314`	`tflog.Info(ctx, DLPX+INFO+"Job result is "+job_res)`
`315`	`315`	`if job_res == Failed \|\| job_res == Canceled \|\| job_res == Abandoned {`
`316`		`- tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+*apiRes.Job.Id+"!")`
`317`		`- return diag.Errorf("[NOT OK] Job %s %s with error %s", *apiRes.Job.Id, job_res, job_err)`
	`316`	`+ tflog.Error(ctx, DLPX+ERROR+"Job "+job_res+" "+apiRes.Job.GetId()+"!")`
	`317`	`+ return diag.Errorf("[NOT OK] Job %s %s with error %s", apiRes.Job.GetId(), job_res, job_err)`
`318`	`318`	`}`
`319`	`319`	`return nil`
`320`	`320`	`}`