diff --git a/orca-clouddriver/src/main/groovy/com/netflix/spinnaker/orca/clouddriver/tasks/providers/aws/cloudformation/CloudFormationForceCacheRefreshTask.java b/orca-clouddriver/src/main/groovy/com/netflix/spinnaker/orca/clouddriver/tasks/providers/aws/cloudformation/CloudFormationForceCacheRefreshTask.java index 88525d234f..22852cecfc 100644 --- a/orca-clouddriver/src/main/groovy/com/netflix/spinnaker/orca/clouddriver/tasks/providers/aws/cloudformation/CloudFormationForceCacheRefreshTask.java +++ b/orca-clouddriver/src/main/groovy/com/netflix/spinnaker/orca/clouddriver/tasks/providers/aws/cloudformation/CloudFormationForceCacheRefreshTask.java @@ -16,7 +16,7 @@ package com.netflix.spinnaker.orca.clouddriver.tasks.providers.aws.cloudformation; -import com.netflix.spinnaker.orca.Task; +import com.netflix.spinnaker.orca.OverridableTimeoutRetryableTask; import com.netflix.spinnaker.orca.TaskResult; import com.netflix.spinnaker.orca.clouddriver.CloudDriverCacheService; import com.netflix.spinnaker.orca.clouddriver.tasks.AbstractCloudProviderAwareTask; @@ -24,17 +24,21 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.TimeUnit; import javax.annotation.Nonnull; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class CloudFormationForceCacheRefreshTask extends AbstractCloudProviderAwareTask - implements Task { + implements OverridableTimeoutRetryableTask { static final String REFRESH_TYPE = "CloudFormation"; @Autowired CloudDriverCacheService cacheService; + private final long backoffPeriod = TimeUnit.SECONDS.toMillis(10); + private final long timeout = TimeUnit.MINUTES.toMillis(5); + @Override public TaskResult execute(@Nonnull Stage stage) { String cloudProvider = getCloudProvider(stage); @@ -60,4 +64,14 @@ public TaskResult execute(@Nonnull Stage stage) { return TaskResult.SUCCEEDED; } + + @Override + public long getBackoffPeriod() { + return backoffPeriod; + } + + @Override + public long getTimeout() { + return timeout; + } }