Skip to content

Commit 42cd238

Browse files
author
Thomas Mahlberg
committed
Some fixes and cleanup
1 parent 157e99d commit 42cd238

2 files changed

Lines changed: 4 additions & 131 deletions

File tree

KustoSchemaTools/Changes/MaterializedViewChange.cs

Lines changed: 0 additions & 127 deletions
This file was deleted.

KustoSchemaTools/Parser/KustoWriter/DefaultDatabaseWriter.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -51,13 +51,13 @@ private async Task<List<ScriptExecuteCommandResult>> ApplyChangesToDatabase(stri
5151
}
5252
else
5353
{
54-
var batchResults = await ExecutePendingSync(databaseName, client, logger, scripts);
54+
var batchResults = await ExecutePendingSync(databaseName, client, logger, batch);
5555
results.AddRange(batchResults);
5656
var asyncResult = await ExecuteAsyncCommand(databaseName, client, logger, sc);
5757
results.Add(asyncResult);
5858
}
5959
}
60-
var finalBatchResults = await ExecutePendingSync(databaseName, client, logger, scripts);
60+
var finalBatchResults = await ExecutePendingSync(databaseName, client, logger, batch);
6161
results.AddRange(finalBatchResults);
6262
return results;
6363

@@ -80,8 +80,8 @@ private async Task<ScriptExecuteCommandResult> ExecuteAsyncCommand(string databa
8080
finalState = true;
8181
}
8282
await Task.Delay(1000);
83-
var monitoringResult = await client.AdminClient.ExecuteControlCommandAsync(databaseName, sc.Text);
84-
var operationState = result.As<ScriptExecuteCommandResult>().FirstOrDefault();
83+
var monitoringResult = client.Client.ExecuteQuery(databaseName, monitoringCommand, new Kusto.Data.Common.ClientRequestProperties());
84+
var operationState = monitoringResult.As<ScriptExecuteCommandResult>().FirstOrDefault();
8585

8686
if (operationState != null && operationState?.IsFinal() == true)
8787
{

0 commit comments

Comments
 (0)