Adding timeout on execution of postgres and ms sql actions (#5922)

This commit is contained in:
Trisha Anand 2021-07-16 20:24:18 +05:30
parent 640959788c
commit 189f4a9069
2 changed files with 5 additions and 0 deletions

View File

@ -15,6 +15,7 @@ import com.appsmith.external.models.DatasourceConfiguration;
import com.appsmith.external.models.DatasourceTestResult;
import com.appsmith.external.models.Endpoint;
import com.appsmith.external.models.Property;
import com.appsmith.external.models.PsParameterDTO;
import com.appsmith.external.models.RequestParamDTO;
import com.appsmith.external.models.SSLDetails;
import com.appsmith.external.plugins.BasePlugin;
@ -44,6 +45,7 @@ import java.sql.Statement;
import java.sql.Time;
import java.sql.Timestamp;
import java.sql.Types;
import java.time.Duration;
import java.time.LocalDateTime;
import java.time.OffsetDateTime;
import java.time.format.DateTimeFormatter;
@ -324,6 +326,7 @@ public class MssqlPlugin extends BasePlugin {
result.setRequest(request);
return result;
})
.timeout(Duration.ofMillis(actionConfiguration.getTimeoutInMillisecond()))
.subscribeOn(scheduler);
}

View File

@ -48,6 +48,7 @@ import java.sql.Statement;
import java.sql.Time;
import java.sql.Timestamp;
import java.sql.Types;
import java.time.Duration;
import java.time.LocalDateTime;
import java.time.OffsetDateTime;
import java.time.format.DateTimeFormatter;
@ -411,6 +412,7 @@ public class PostgresPlugin extends BasePlugin {
result.setRequest(request);
return result;
})
.timeout(Duration.ofMillis(actionConfiguration.getTimeoutInMillisecond()))
.subscribeOn(scheduler);
}