Fix task reschedule policy (#3413)

temporalio · Sep 29, 2022 · ac2593c · ac2593c
1 parent 0603535
commit ac2593c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/service/history/queues/executable.go b/service/history/queues/executable.go
@@ -82,7 +82,7 @@ var (
 	// across multiple submissions to scheduler
 	reschedulePolicy                      = common.CreateTaskReschedulePolicy()
 	taskNotReadyReschedulePolicy          = common.CreateTaskNotReadyReschedulePolicy()
-	taskResourceExhuastedReschedulePolicy = common.CreateTaskNotReadyReschedulePolicy()
+	taskResourceExhuastedReschedulePolicy = common.CreateTaskResourceExhaustedReschedulePolicy()
 )
 
 const (
@@ -455,7 +455,7 @@ func (e *executableImpl) rescheduleTime(
 		// using a different reschedule policy to slow down retry
 		// as the error means mutable state is not ready to handle the task,
 		// need to wait for replication.
-		e.timeSource.Now().Add(taskNotReadyReschedulePolicy.ComputeNextDelay(0, attempt))
+		return e.timeSource.Now().Add(taskNotReadyReschedulePolicy.ComputeNextDelay(0, attempt))
 	}
 
 	backoff := reschedulePolicy.ComputeNextDelay(0, attempt)