in plugin-azure-server/src/main/kotlin/jetbrains/buildServer/clouds/azure/arm/throttler/AzureThrottlerStrategyImpl.kt [98:124]
override fun notifyCompleted(performedRequests: Boolean) {
myLock.lock();
try {
if (performedRequests && !mySuccessfullExecutionFlag.get()) {
mySuccessfullExecutionFlag.set(true)
val taskList = taskContainer.getTaskList()
for(task in taskList) {
task.enableRetryOnThrottle()
}
}
if (myFlow.get() == AzureThrottlerFlow.Suspended) {
LOG.debug("Task completed successfully, switching Suspended state to Normal")
myFlow.set(AzureThrottlerFlow.Normal)
val taskList = taskContainer.getTaskList()
for (task in taskList) {
task.notifyCompleted(performedRequests)
}
}
}
finally {
myLock.unlock()
}
}