diff --git a/third_party/terraform/resources/resource_dataflow_job.go b/third_party/terraform/resources/resource_dataflow_job.go
index f58bd07c2dd6..16c2409d4c92 100644
--- a/third_party/terraform/resources/resource_dataflow_job.go
+++ b/third_party/terraform/resources/resource_dataflow_job.go
@@ -522,6 +522,9 @@ func waitForDataflowJobToBeUpdated(d *schema.ResourceData, config *Config, repla
 
 		replacementJob, err := resourceDataflowJobGetJob(config, project, region, replacementJobID)
 		if err != nil {
+			if isRetryableError(err) {
+				return resource.RetryableError(err)
+			}
 			return resource.NonRetryableError(err)
 		}