Skip to content

Commit

Permalink
dataproc_job add support for job status RUNNING (#4341) (#2809)
Browse files Browse the repository at this point in the history
Signed-off-by: Modular Magician <[email protected]>
  • Loading branch information
modular-magician authored Dec 22, 2020
1 parent eac6d73 commit a4751c0
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
3 changes: 3 additions & 0 deletions .changelog/4341.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:bug
dataproc: jobs no longer wait for job completion during create
```
4 changes: 2 additions & 2 deletions google-beta/dataproc_job_operation.go
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down

0 comments on commit a4751c0

Please sign in to comment.