Merge branch 'release' into pg

appsmithorg · Feb 11, 2025 · ed6cfcb · ed6cfcb
2 parents 86d9a58 + 9aa065b
commit ed6cfcb
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/app/server/appsmith-plugins/mssqlPlugin/src/main/java/com/external/plugins/MssqlPlugin.java b/app/server/appsmith-plugins/mssqlPlugin/src/main/java/com/external/plugins/MssqlPlugin.java
@@ -363,15 +363,14 @@ private Set<String> populateHintMessages(List<String> columnNames) {
         @Override
         public Mono<HikariDataSource> datasourceCreate(DatasourceConfiguration datasourceConfiguration) {
             log.debug(Thread.currentThread().getName() + ": datasourceCreate() called for MSSQL plugin.");
-            return connectionPoolConfig
-                    .getMaxConnectionPoolSize()
-                    .flatMap(maxPoolSize -> {
+            return Mono.defer(
+                    () -> connectionPoolConfig.getMaxConnectionPoolSize().flatMap(maxPoolSize -> {
                         return Mono.fromCallable(() -> {
-                            log.debug(Thread.currentThread().getName() + ": Connecting to SQL Server db");
-                            return createConnectionPool(datasourceConfiguration, maxPoolSize);
-                        });
-                    })
-                    .subscribeOn(scheduler);
+                                    log.debug(Thread.currentThread().getName() + ": Connecting to SQL Server db");
+                                    return createConnectionPool(datasourceConfiguration, maxPoolSize);
+                                })
+                                .subscribeOn(scheduler);
+                    }));
         }
 
         @Override