diff --git a/PluginSnowflake/API/Replication/WriteRecord.cs b/PluginSnowflake/API/Replication/WriteRecord.cs
index aec7b0a..8200570 100644
--- a/PluginSnowflake/API/Replication/WriteRecord.cs
+++ b/PluginSnowflake/API/Replication/WriteRecord.cs
@@ -16,8 +16,8 @@ namespace PluginSnowflake.API.Replication
 {
     public static partial class Replication
     {
-        private static readonly SemaphoreSlim ReplicationSemaphoreSlim = new SemaphoreSlim(1, 1);
-        
+        private static readonly SemaphoreSlim ReplicationSemaphoreSlim = new SemaphoreSlim(10, 10);
+
         /// <summary>
         /// Adds and removes records to replication db
         /// Adds and updates available shapes
@@ -59,19 +59,12 @@ public static async Task<string> WriteRecord(IConnectionFactory connFactory, Sch
             
                 // get previous golden record
                 List<string> previousRecordVersionIds;
-                if (await RecordExistsAsync(connFactory, goldenTable, record.RecordId))
+                var recordMap = await GetRecordAsync(connFactory, goldenTable, record.RecordId);
+
+                if (recordMap != null && recordMap.ContainsKey(Constants.ReplicationVersionIds))
                 {
-                    var recordMap = await GetRecordAsync(connFactory, goldenTable, record.RecordId);
-            
-                    if (recordMap.ContainsKey(Constants.ReplicationVersionIds))
-                    {
-                        previousRecordVersionIds =
-                            JsonConvert.DeserializeObject<List<string>>(recordMap[Constants.ReplicationVersionIds].ToString());
-                    }
-                    else
-                    {
-                        previousRecordVersionIds = recordVersionIds;
-                    }
+                    previousRecordVersionIds =
+                        JsonConvert.DeserializeObject<List<string>>(recordMap[Constants.ReplicationVersionIds].ToString());
                 }
                 else
                 {
diff --git a/PluginSnowflake/Helper/Settings.cs b/PluginSnowflake/Helper/Settings.cs
index 1910db2..fe3d1bb 100644
--- a/PluginSnowflake/Helper/Settings.cs
+++ b/PluginSnowflake/Helper/Settings.cs
@@ -48,7 +48,7 @@ public void Validate()
         /// <returns></returns>
         public string GetConnectionString()
         {
-            return $"account={Account};user={Username};password={Password};db={Database};warehouse={Warehouse};";
+            return $"account={Account};user={Username};password={Password};db={Database};warehouse={Warehouse};maxPoolSize=50;";
         }
         
         /// <summary>
@@ -57,7 +57,7 @@ public string GetConnectionString()
         /// <returns></returns>
         public string GetConnectionString(string database)
         {
-            return $"account={Account};user={Username};password={Password};db={database};warehouse={Warehouse};";
+            return $"account={Account};user={Username};password={Password};db={database};warehouse={Warehouse};maxPoolSize=50;";
         }
     }
 }
\ No newline at end of file
diff --git a/PluginSnowflake/PluginSnowflake.csproj b/PluginSnowflake/PluginSnowflake.csproj
index a12eeab..e755870 100644
--- a/PluginSnowflake/PluginSnowflake.csproj
+++ b/PluginSnowflake/PluginSnowflake.csproj
@@ -7,12 +7,12 @@
 
     <ItemGroup>
         <PackageReference Include="Aunalytics.Sdk" Version="1.3.0" />
-        <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
+        <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
         <PackageReference Include="Serilog" Version="2.10.0" />
         <PackageReference Include="Serilog.Sinks.Async" Version="1.4.0" />
         <PackageReference Include="Serilog.Sinks.Console" Version="3.1.1" />
         <PackageReference Include="Serilog.Sinks.File" Version="4.1.0" />
-        <PackageReference Include="Snowflake.Data" Version="1.2.0" />
+        <PackageReference Include="Snowflake.Data" Version="4.2.0" />
         <PackageReference Include="System.Linq.Async" Version="4.0.0" />
     </ItemGroup>
 
diff --git a/PluginSnowflakeTest/PluginSnowflakeTest.csproj b/PluginSnowflakeTest/PluginSnowflakeTest.csproj
index 7af8855..fe1adb1 100644
--- a/PluginSnowflakeTest/PluginSnowflakeTest.csproj
+++ b/PluginSnowflakeTest/PluginSnowflakeTest.csproj
@@ -9,7 +9,7 @@
         <PackageReference Include="Microsoft.NET.Test.Sdk" Version="16.4.0" />
         <PackageReference Include="Moq" Version="4.13.1" />
         <PackageReference Include="Aunalytics.Sdk" Version="1.3.0" />
-        <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
+        <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
         <PackageReference Include="xunit" Version="2.4.0" />
         <PackageReference Include="xunit.runner.visualstudio" Version="2.4.0" />
     </ItemGroup>