mirror of
https://github.com/google/nomulus
synced 2026-01-03 19:54:18 +00:00
Rename async flow failure backoff config property
------------- Created by MOE: https://github.com/google/moe MOE_MIGRATED_REVID=118207124
This commit is contained in:
@@ -253,10 +253,10 @@ public interface RegistryConfig {
|
||||
public Duration getAsyncDeleteFlowMapreduceDelay();
|
||||
|
||||
/**
|
||||
* Returns the amount of time to back off following an async delete flow task failure.
|
||||
* Returns the amount of time to back off following an async flow task failure.
|
||||
*
|
||||
* This should be ~orders of magnitude larger than the rate on the queue, in order to prevent
|
||||
* the logs from filling up with unnecessarily failures.
|
||||
*/
|
||||
public Duration getAsyncDeleteFlowFailureBackoff();
|
||||
public Duration getAsyncFlowFailureBackoff();
|
||||
}
|
||||
|
||||
@@ -190,7 +190,7 @@ public class TestRegistryConfig implements RegistryConfig {
|
||||
}
|
||||
|
||||
@Override
|
||||
public Duration getAsyncDeleteFlowFailureBackoff() {
|
||||
public Duration getAsyncFlowFailureBackoff() {
|
||||
return Duration.standardMinutes(10);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -52,7 +52,7 @@ public final class AsyncFlowUtils {
|
||||
logger.infofmt("Enqueueing async mapreduce action with path %s and params %s", path, params);
|
||||
// Aggressively back off if the task fails, to minimize flooding the logs.
|
||||
RetryOptions retryOptions = RetryOptions.Builder.withMinBackoffSeconds(
|
||||
RegistryEnvironment.get().config().getAsyncDeleteFlowFailureBackoff().getStandardSeconds());
|
||||
RegistryEnvironment.get().config().getAsyncFlowFailureBackoff().getStandardSeconds());
|
||||
TaskOptions options = TaskOptions.Builder
|
||||
.withUrl(path)
|
||||
.retryOptions(retryOptions)
|
||||
|
||||
Reference in New Issue
Block a user