diff --git a/.changelog/4341.txt b/.changelog/4341.txt new file mode 100644 index 0000000000..7279eda093 --- /dev/null +++ b/.changelog/4341.txt @@ -0,0 +1,3 @@ +```release-note:bug +dataproc: jobs no longer wait for job completion during create +``` diff --git a/google-beta/dataproc_job_operation.go b/google-beta/dataproc_job_operation.go index 62ba06a060..0ab20d2a09 100644 --- a/google-beta/dataproc_job_operation.go +++ b/google-beta/dataproc_job_operation.go @@ -59,11 +59,11 @@ func (w *DataprocJobOperationWaiter) OpName() string { } func (w *DataprocJobOperationWaiter) PendingStates() []string { - return []string{"PENDING", "CANCEL_PENDING", "CANCEL_STARTED", "SETUP_DONE", "RUNNING"} + return []string{"PENDING", "CANCEL_PENDING", "CANCEL_STARTED", "SETUP_DONE"} } func (w *DataprocJobOperationWaiter) TargetStates() []string { - return []string{"CANCELLED", "DONE", "ATTEMPT_FAILURE", "ERROR"} + return []string{"CANCELLED", "DONE", "ATTEMPT_FAILURE", "ERROR", "RUNNING"} } func dataprocJobOperationWait(config *Config, region, projectId, jobId, activity, userAgent string, timeout time.Duration) error {