249
250
// CreateTaskReschedulePolicy creates a retry policy for rescheduling task with errors not equal to ErrTaskRetry
251
>
func CreateTaskReschedulePolicy() backoff.RetryPolicy {
util.go
252
>
return backoff.NewExponentialRetryPolicy(taskRescheduleInitialInterval).
253
>
WithBackoffCoefficient(taskRescheduleBackoffCoefficient).
254
>
WithMaximumInterval(taskRescheduleMaxInterval).
255
>
WithExpirationInterval(backoff.NoInterval)
256
>
}
257
258
// CreateDependencyTaskNotCompletedReschedulePolicy creates a retry policy for rescheduling task with
259
// ErrDependencyTaskNotCompleted
260
>
func CreateDependencyTaskNotCompletedReschedulePolicy() backoff.RetryPolicy {
util.go
261
>
return backoff.NewExponentialRetryPolicy(dependencyTaskNotCompletedRescheduleInitialInterval).
262
>
WithBackoffCoefficient(dependencyTaskNotCompletedRescheduleBackoffCoefficient).
263
>
WithMaximumInterval(dependencyTaskNotCompletedRescheduleMaxInterval).
264
>
WithExpirationInterval(backoff.NoInterval)
265
>
}
266
267
// CreateTaskNotReadyReschedulePolicy creates a retry policy for rescheduling task with ErrTaskRetry
268
>
func CreateTaskNotReadyReschedulePolicy() backoff.RetryPolicy {
util.go
269
>
return backoff.NewExponentialRetryPolicy(taskNotReadyRescheduleInitialInterval).
270
>
WithBackoffCoefficient(taskNotReadyRescheduleBackoffCoefficient).
271
>
WithMaximumInterval(taskNotReadyRescheduleMaxInterval).
272
>
WithExpirationInterval(backoff.NoInterval)
273
>
}
274
275
// CreateTaskResourceExhaustedReschedulePolicy creates a retry policy for rescheduling task with resource exhausted error
276
>
func CreateTaskResourceExhaustedReschedulePolicy() backoff.RetryPolicy {
util.go
277
>
return backoff.NewExponentialRetryPolicy(taskResourceExhaustedRescheduleInitialInterval).
278
>
WithBackoffCoefficient(taskResourceExhaustedRescheduleBackoffCoefficient).
279
>
WithMaximumInterval(taskResourceExhaustedRescheduleMaxInterval).
280
>
WithExpirationInterval(backoff.NoInterval)
281
>
}
282
283
// CreateSdkClientFactoryRetryPolicy creates a retry policy to handle SdkClientFactory NewClient when frontend service is not ready