Skip to content

Commit 5c33794

Browse files
committed
Match command concurrency with queries
1 parent c60c698 commit 5c33794

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

code/KustoCopyConsole/Kusto/DbClientFactory.cs

+1-2
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ namespace KustoCopyConsole.Kusto
1717
internal class DbClientFactory : IDisposable
1818
{
1919
private const int MAX_CONCURRENT_DM_COMMAND = 2;
20-
private const int MAX_CONCURRENT_DB_COMMAND = 10;
2120

2221
private readonly ProviderFactory _providerFactory;
2322
private readonly IImmutableDictionary<Uri, PriorityExecutionQueue<KustoPriority>> _allClusterQueryQueueMap;
@@ -65,7 +64,7 @@ public static async Task<DbClientFactory> CreateAsync(
6564
var allClusterCommandQueueMap = allClusterQueryCount
6665
.ToImmutableDictionary(
6766
o => o.Uri,
68-
o => new PriorityExecutionQueue<KustoPriority>(MAX_CONCURRENT_DB_COMMAND));
67+
o => new PriorityExecutionQueue<KustoPriority>(o.ConcurrentQueryCount));
6968
var destinationClusterDmQueryQueueMap = destinationClusterUris
7069
.ToImmutableDictionary(
7170
u => u,

0 commit comments

Comments
 (0)