diff --git a/src/Microsoft.Kusto.ServiceLayer/Connection/ConnectionService.cs b/src/Microsoft.Kusto.ServiceLayer/Connection/ConnectionService.cs
index 3c67aecd..1778c0fb 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Connection/ConnectionService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Connection/ConnectionService.cs
@@ -17,7 +17,6 @@ using Microsoft.Kusto.ServiceLayer.Connection.Contracts;
using Microsoft.Kusto.ServiceLayer.LanguageServices;
using Microsoft.Kusto.ServiceLayer.LanguageServices.Contracts;
using Microsoft.SqlTools.Utility;
-using System.Diagnostics;
using Microsoft.Kusto.ServiceLayer.DataSource;
using Microsoft.Kusto.ServiceLayer.DataSource.Metadata;
using Microsoft.SqlTools.ServiceLayer.Connection.ReliableConnection;
@@ -246,7 +245,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Information, "Failed to close temporary connections. error: " + ex.Message);
+ Logger.Information("Failed to close temporary connections. error: " + ex.Message);
}
}
@@ -769,7 +768,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
///
private async Task HandleConnectRequest(ConnectParams connectParams, RequestContext requestContext)
{
- Logger.Write(TraceEventType.Verbose, "HandleConnectRequest");
+ Logger.Verbose("HandleConnectRequest");
try
{
@@ -807,7 +806,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
CancelConnectParams cancelParams,
RequestContext requestContext)
{
- Logger.Write(TraceEventType.Verbose, "HandleCancelConnectRequest");
+ Logger.Verbose("HandleCancelConnectRequest");
try
{
@@ -825,7 +824,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
///
private async Task HandleDisconnectRequest(DisconnectParams disconnectParams, RequestContext requestContext)
{
- Logger.Write(TraceEventType.Verbose, "HandleDisconnectRequest");
+ Logger.Verbose("HandleDisconnectRequest");
try
{
@@ -844,7 +843,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
///
private async Task HandleListDatabasesRequest(ListDatabasesParams listDatabasesParams, RequestContext requestContext)
{
- Logger.Write(TraceEventType.Verbose, "ListDatabasesRequest");
+ Logger.Verbose("ListDatabasesRequest");
try
{
@@ -985,8 +984,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
}
catch (Exception e)
{
- Logger.Write(
- TraceEventType.Error,
+ Logger.Error(
$"Exception caught while trying to change database context to [{newDatabaseName}] for OwnerUri [{ownerUri}]. Exception:{e}"
);
return false;
@@ -1049,7 +1047,7 @@ namespace Microsoft.Kusto.ServiceLayer.Connection
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Verbose, "Could not send Connection telemetry event " + ex.ToString());
+ Logger.Verbose("Could not send Connection telemetry event " + ex.ToString());
}
}
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/Formatter/FormatterService.cs b/src/Microsoft.Kusto.ServiceLayer/Formatter/FormatterService.cs
index 42c0b578..4e97b7f4 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Formatter/FormatterService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Formatter/FormatterService.cs
@@ -5,7 +5,6 @@
using System;
using System.Collections.Generic;
-using System.Diagnostics;
using System.Threading.Tasks;
using Microsoft.Kusto.ServiceLayer.DataSource;
using Microsoft.SqlTools.Extensibility;
@@ -37,7 +36,7 @@ namespace Microsoft.Kusto.ServiceLayer.Formatter
public override void InitializeService(IProtocolEndpoint serviceHost)
{
- Logger.Write(TraceEventType.Verbose, "TSqlFormatter initialized");
+ Logger.Verbose("TSqlFormatter initialized");
serviceHost.SetRequestHandler(DocumentFormattingRequest.Type, HandleDocFormatRequest);
serviceHost.SetRequestHandler(DocumentRangeFormattingRequest.Type, HandleDocRangeFormatRequest);
WorkspaceService?.RegisterConfigChangeCallback(HandleDidChangeConfigurationNotification);
@@ -227,7 +226,7 @@ namespace Microsoft.Kusto.ServiceLayer.Formatter
private async Task HandleRequest(Func> handler, RequestContext requestContext, string requestType)
{
- Logger.Write(TraceEventType.Verbose, requestType);
+ Logger.Verbose(requestType);
try
{
diff --git a/src/Microsoft.Kusto.ServiceLayer/LanguageServices/BindingQueue.cs b/src/Microsoft.Kusto.ServiceLayer/LanguageServices/BindingQueue.cs
index e9efc8fa..6fd77380 100644
--- a/src/Microsoft.Kusto.ServiceLayer/LanguageServices/BindingQueue.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/LanguageServices/BindingQueue.cs
@@ -8,7 +8,6 @@
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
-using System.Diagnostics;
using System.Linq;
using System.Net.Sockets;
using System.Threading;
@@ -312,14 +311,14 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
{
try
{
- Logger.Write(TraceEventType.Warning, "Binding queue operation timed out waiting for previous operation to finish");
+ Logger.Warning("Binding queue operation timed out waiting for previous operation to finish");
queueItem.Result = queueItem.TimeoutOperation != null
? queueItem.TimeoutOperation(bindingContext)
: null;
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Exception running binding queue lock timeout handler: " + ex.ToString());
+ Logger.Error("Exception running binding queue lock timeout handler: " + ex.ToString());
}
finally
{
@@ -348,7 +347,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unexpected exception on the binding queue: " + ex.ToString());
+ Logger.Error("Unexpected exception on the binding queue: " + ex.ToString());
if (queueItem.ErrorHandler != null)
{
try
@@ -357,7 +356,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex2)
{
- Logger.Write(TraceEventType.Error, "Unexpected exception in binding queue error handler: " + ex2.ToString());
+ Logger.Error("Unexpected exception in binding queue error handler: " + ex2.ToString());
}
}
@@ -392,7 +391,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
queueItem.Result = queueItem.TimeoutOperation(bindingContext);
}
- bindTask.ContinueWithOnFaulted(t => Logger.Write(TraceEventType.Error, "Binding queue threw exception " + t.Exception.ToString()));
+ bindTask.ContinueWithOnFaulted(t => Logger.Error("Binding queue threw exception " + t.Exception.ToString()));
// Give the task a chance to complete before moving on to the next operation
bindTask.Wait();
@@ -400,7 +399,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Binding queue task completion threw exception " + ex.ToString());
+ Logger.Error("Binding queue task completion threw exception " + ex.ToString());
}
finally
{
@@ -417,7 +416,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
{
// catch and log any exceptions raised in the binding calls
// set item processed to avoid deadlocks
- Logger.Write(TraceEventType.Error, "Binding queue threw exception " + ex.ToString());
+ Logger.Error("Binding queue threw exception " + ex.ToString());
// set item processed to avoid deadlocks
if (lockTaken)
{
diff --git a/src/Microsoft.Kusto.ServiceLayer/LanguageServices/LanguageService.cs b/src/Microsoft.Kusto.ServiceLayer/LanguageServices/LanguageService.cs
index 42f8f994..a750657d 100644
--- a/src/Microsoft.Kusto.ServiceLayer/LanguageServices/LanguageService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/LanguageServices/LanguageService.cs
@@ -8,7 +8,6 @@
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
-using System.Diagnostics;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
@@ -219,7 +218,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
// Register a no-op shutdown task for validation of the shutdown logic
serviceHost.RegisterShutdownTask(async (shutdownParams, shutdownRequestContext) =>
{
- Logger.Write(TraceEventType.Verbose, "Shutting down language service");
+ Logger.Verbose("Shutting down language service");
DeletePeekDefinitionScripts();
this.Dispose();
await Task.FromResult(0);
@@ -495,7 +494,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
// TODO: need mechanism return errors from event handlers
}
}
@@ -521,7 +520,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
// TODO: need mechanism return errors from event handlers
}
}
@@ -535,7 +534,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
{
try
{
- Logger.Write(TraceEventType.Verbose, "HandleRebuildIntelliSenseNotification");
+ Logger.Verbose("HandleRebuildIntelliSenseNotification");
// Skip closing this file if the file doesn't exist
var scriptFile = this.CurrentWorkspace.GetFile(rebuildParams.OwnerUri);
@@ -565,7 +564,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
}
finally
{
@@ -595,7 +594,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
await ServiceHostInstance.SendEvent(IntelliSenseReadyNotification.Type, new IntelliSenseReadyParams() {OwnerUri = rebuildParams.OwnerUri});
}
}
@@ -642,7 +641,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
// TODO: need mechanism return errors from event handlers
}
}
@@ -684,7 +683,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error in OnConnection " + ex.ToString());
+ Logger.Error("Unknown error in OnConnection " + ex.ToString());
scriptInfo.IsConnected = false;
}
finally
@@ -907,7 +906,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
}
catch (Exception e)
{
- Logger.Write(TraceEventType.Error, string.Format("Exception while cancelling analysis task:\n\n{0}", e.ToString()));
+ Logger.Error(string.Format("Exception while cancelling analysis task:\n\n{0}", e.ToString()));
TaskCompletionSource cancelTask = new TaskCompletionSource();
cancelTask.SetCanceled();
@@ -978,7 +977,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
continue;
}
- Logger.Write(TraceEventType.Verbose, "Analyzing script file: " + scriptFile.FilePath);
+ Logger.Verbose("Analyzing script file: " + scriptFile.FilePath);
// TODOKusto: Add file for mapping here, parity from parseAndbind function. Confirm it.
ScriptParseInfo parseInfo = GetScriptParseInfo(scriptFile.ClientUri, createIfNotExists: true);
@@ -999,7 +998,7 @@ namespace Microsoft.Kusto.ServiceLayer.LanguageServices
semanticMarkers = DataSourceFactory.GetDefaultSemanticMarkers(DataSourceType.Kusto, parseInfo, scriptFile, scriptFile.Contents);
}
- Logger.Write(TraceEventType.Verbose, "Analysis complete.");
+ Logger.Verbose("Analysis complete.");
await DiagnosticsHelper.PublishScriptDiagnostics(scriptFile, semanticMarkers, eventContext);
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/DataSourceModel/ServerNode.cs b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/DataSourceModel/ServerNode.cs
index afad6d11..9ce3a041 100644
--- a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/DataSourceModel/ServerNode.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/DataSourceModel/ServerNode.cs
@@ -4,7 +4,6 @@
//
using System;
-using System.Diagnostics;
using System.Globalization;
using Microsoft.SqlTools.Extensibility;
using Microsoft.Kusto.ServiceLayer.Connection.Contracts;
@@ -113,7 +112,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.DataSourceModel
exceptionMessage = ex.Message;
}
- Logger.Write(TraceEventType.Error, "Exception at ServerNode.CreateContext() : " + exceptionMessage);
+ Logger.Error("Exception at ServerNode.CreateContext() : " + exceptionMessage);
this.ErrorStateMessage = string.Format(SR.TreeNodeError, exceptionMessage);
return null;
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/Nodes/TreeNode.cs b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/Nodes/TreeNode.cs
index 56566a55..ceb7e8b8 100644
--- a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/Nodes/TreeNode.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/Nodes/TreeNode.cs
@@ -307,7 +307,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
protected void PopulateChildren(bool refresh, string name, CancellationToken cancellationToken)
{
- Logger.Write(TraceEventType.Verbose, string.Format(CultureInfo.InvariantCulture, "Populating oe node :{0}", this.GetNodePath()));
+ Logger.Verbose(string.Format(CultureInfo.InvariantCulture, "Populating oe node :{0}", this.GetNodePath()));
Debug.Assert(IsAlwaysLeaf == false);
QueryContext context = this.GetContextAs();
@@ -338,7 +338,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
{
string error = string.Format(CultureInfo.InvariantCulture, "Failed populating oe children. error:{0} inner:{1} stacktrace:{2}",
ex.Message, ex.InnerException != null ? ex.InnerException.Message : "", ex.StackTrace);
- Logger.Write(TraceEventType.Error, error);
+ Logger.Error(error);
ErrorMessage = ex.Message;
}
finally
@@ -360,7 +360,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
"Failed expanding oe children. parent:{0} error:{1} inner:{2} stacktrace:{3}",
parent != null ? parent.GetNodePath() : "", ex.Message,
ex.InnerException != null ? ex.InnerException.Message : "", ex.StackTrace);
- Logger.Write(TraceEventType.Error, error);
+ Logger.Error(error);
throw;
}
}
@@ -372,7 +372,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
/// Parent the nodes are being added to
private List OnExpandPopulateNonFolders(TreeNode parent, bool refresh, string name, CancellationToken cancellationToken)
{
- Logger.Write(TraceEventType.Verbose, string.Format(CultureInfo.InvariantCulture, "child factory parent :{0}", parent.GetNodePath()));
+ Logger.Verbose(string.Format(CultureInfo.InvariantCulture, "child factory parent :{0}", parent.GetNodePath()));
cancellationToken.ThrowIfCancellationRequested();
@@ -396,7 +396,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
cancellationToken.ThrowIfCancellationRequested();
if (objectMetadata == null)
{
- Logger.Write(TraceEventType.Error, "kustoMetadata should not be null");
+ Logger.Error("kustoMetadata should not be null");
}
TreeNode childNode = CreateChild(parent, objectMetadata);
if (childNode != null)
@@ -411,7 +411,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer.Nodes
{
string error = string.Format(CultureInfo.InvariantCulture, "Failed getting child objects. parent:{0} error:{1} inner:{2} stacktrace:{3}",
parent != null ? parent.GetNodePath() : "", ex.Message, ex.InnerException != null ? ex.InnerException.Message : "", ex.StackTrace);
- Logger.Write(TraceEventType.Error, error);
+ Logger.Error(error);
throw;
}
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/ObjectExplorerService.cs b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/ObjectExplorerService.cs
index 8d879896..628b363b 100644
--- a/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/ObjectExplorerService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/ObjectExplorer/ObjectExplorerService.cs
@@ -9,7 +9,6 @@ using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Collections.ObjectModel;
-using System.Diagnostics;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;
@@ -91,7 +90,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
}
catch(Exception ex)
{
- Logger.Write(TraceEventType.Error, ex.Message);
+ Logger.Error(ex.Message);
}
}
@@ -101,7 +100,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
/// The service host instance to register with
public override void InitializeService(IProtocolEndpoint serviceHost)
{
- Logger.Write(TraceEventType.Verbose, "ObjectExplorer service initialized");
+ Logger.Verbose("ObjectExplorer service initialized");
_serviceHost = serviceHost;
_connectedBindingQueue.OnUnhandledException += OnUnhandledException;
@@ -139,7 +138,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
{
try
{
- Logger.Write(TraceEventType.Verbose, "HandleCreateSessionRequest");
+ Logger.Verbose("HandleCreateSessionRequest");
Func> doCreateSession = async () =>
{
Validate.IsNotNull(nameof(connectionDetails), connectionDetails);
@@ -167,7 +166,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
internal async Task HandleExpandRequest(ExpandParams expandParams, RequestContext context)
{
- Logger.Write(TraceEventType.Verbose, "HandleExpandRequest");
+ Logger.Verbose("HandleExpandRequest");
Func> expandNode = async () =>
{
@@ -178,7 +177,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
ObjectExplorerSession session = null;
if (!_sessionMap.TryGetValue(uri, out session))
{
- Logger.Write(TraceEventType.Verbose, $"Cannot expand object explorer node. Couldn't find session for uri. {uri} ");
+ Logger.Verbose($"Cannot expand object explorer node. Couldn't find session for uri. {uri} ");
await _serviceHost.SendEvent(ExpandCompleteNotification.Type, new ExpandResponse
{
SessionId = expandParams.SessionId,
@@ -200,7 +199,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
{
try
{
- Logger.Write(TraceEventType.Verbose, "HandleRefreshRequest");
+ Logger.Verbose("HandleRefreshRequest");
Validate.IsNotNull(nameof(refreshParams), refreshParams);
Validate.IsNotNull(nameof(context), context);
@@ -208,7 +207,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
ObjectExplorerSession session = null;
if (!_sessionMap.TryGetValue(uri, out session))
{
- Logger.Write(TraceEventType.Verbose, $"Cannot expand object explorer node. Couldn't find session for uri. {uri} ");
+ Logger.Verbose($"Cannot expand object explorer node. Couldn't find session for uri. {uri} ");
await _serviceHost.SendEvent(ExpandCompleteNotification.Type, new ExpandResponse
{
SessionId = refreshParams.SessionId,
@@ -231,7 +230,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
internal async Task HandleCloseSessionRequest(CloseSessionParams closeSessionParams, RequestContext context)
{
- Logger.Write(TraceEventType.Verbose, "HandleCloseSessionRequest");
+ Logger.Verbose("HandleCloseSessionRequest");
Func> closeSession = () =>
{
Validate.IsNotNull(nameof(closeSessionParams), closeSessionParams);
@@ -243,7 +242,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
bool success = false;
if (!_sessionMap.TryGetValue(uri, out session))
{
- Logger.Write(TraceEventType.Verbose, $"Cannot close object explorer session. Couldn't find session for uri. {uri} ");
+ Logger.Verbose($"Cannot close object explorer session. Couldn't find session for uri. {uri} ");
}
if (session != null)
@@ -290,7 +289,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
private void RunCreateSessionTask(ConnectionDetails connectionDetails, string uri)
{
- Logger.Write(TraceEventType.Information, "Creating OE session");
+ Logger.Information("Creating OE session");
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
if (connectionDetails != null && !string.IsNullOrEmpty(uri))
{
@@ -494,7 +493,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
private async Task SendSessionFailedNotification(string uri, string errorMessage)
{
- Logger.Write(TraceEventType.Warning, $"Failed To create OE session: {errorMessage}");
+ Logger.Warning($"Failed To create OE session: {errorMessage}");
SessionCreatedParameters result = new SessionCreatedParameters()
{
Success = false,
@@ -506,7 +505,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
internal async Task SendSessionDisconnectedNotification(string uri, bool success, string errorMessage)
{
- Logger.Write(TraceEventType.Information, $"OE session disconnected: {errorMessage}");
+ Logger.Information($"OE session disconnected: {errorMessage}");
SessionDisconnectedParameters result = new SessionDisconnectedParameters()
{
Success = success,
@@ -559,7 +558,7 @@ namespace Microsoft.Kusto.ServiceLayer.ObjectExplorer
response = await ExpandNode(session, expandParams.NodePath, forceRefresh);
if (cancellationToken.IsCancellationRequested)
{
- Logger.Write(TraceEventType.Verbose, "OE expand canceled");
+ Logger.Verbose("OE expand canceled");
}
else
{
diff --git a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/Query.cs b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/Query.cs
index c13cde62..0b8bb99a 100644
--- a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/Query.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/Query.cs
@@ -17,7 +17,6 @@ using Microsoft.Kusto.ServiceLayer.SqlContext;
using Microsoft.SqlTools.Utility;
using Microsoft.SqlTools.ServiceLayer.BatchParser.ExecutionEngineCode;
using System.Collections.Generic;
-using System.Diagnostics;
using Microsoft.Kusto.ServiceLayer.Utility;
namespace Microsoft.Kusto.ServiceLayer.QueryExecution
@@ -275,7 +274,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
/// A subset of results
public Task GetSubset(int batchIndex, int resultSetIndex, long startRow, int rowCount)
{
- Logger.Write(TraceEventType.Start, $"Starting GetSubset execution for batchIndex:'{batchIndex}', resultSetIndex:'{resultSetIndex}', startRow:'{startRow}', rowCount:'{rowCount}'");
+ Logger.Start($"Starting GetSubset execution for batchIndex:'{batchIndex}', resultSetIndex:'{resultSetIndex}', startRow:'{startRow}', rowCount:'{rowCount}'");
// Sanity check to make sure that the batch is within bounds
if (batchIndex < 0 || batchIndex >= Batches.Length)
{
diff --git a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/QueryExecutionService.cs b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/QueryExecutionService.cs
index 067c41dc..99fdaafc 100644
--- a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/QueryExecutionService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/QueryExecutionService.cs
@@ -19,7 +19,6 @@ using Microsoft.Kusto.ServiceLayer.SqlContext;
using Microsoft.Kusto.ServiceLayer.Workspace;
using Microsoft.Kusto.ServiceLayer.Workspace.Contracts;
using Microsoft.SqlTools.Utility;
-using System.Diagnostics;
namespace Microsoft.Kusto.ServiceLayer.QueryExecution
{
@@ -208,12 +207,12 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
Func> queryCreateSuccessAction = async q =>
{
await requestContext.SendResult(new ExecuteRequestResult());
- Logger.Write(TraceEventType.Stop, $"Response for Query: '{executeParams.OwnerUri} sent. Query Complete!");
+ Logger.Stop($"Response for Query: '{executeParams.OwnerUri} sent. Query Complete!");
return true;
};
Func queryCreateFailureAction = message =>
{
- Logger.Write(TraceEventType.Warning, $"Failed to create Query: '{executeParams.OwnerUri}. Message: '{message}' Complete!");
+ Logger.Warning($"Failed to create Query: '{executeParams.OwnerUri}. Message: '{message}' Complete!");
return requestContext.SendError(message);
};
@@ -367,7 +366,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
ResultSubset = subset
};
await requestContext.SendResult(result);
- Logger.Write(TraceEventType.Stop, $"Done Handler for Subset request with for Query:'{subsetParams.OwnerUri}', Batch:'{subsetParams.BatchIndex}', ResultSetIndex:'{subsetParams.ResultSetIndex}', RowsStartIndex'{subsetParams.RowsStartIndex}', Requested RowsCount:'{subsetParams.RowsCount}'\r\n\t\t with subset response of:[ RowCount:'{subset.RowCount}', Rows array of length:'{subset.Rows.Length}']");
+ Logger.Stop($"Done Handler for Subset request with for Query:'{subsetParams.OwnerUri}', Batch:'{subsetParams.BatchIndex}', ResultSetIndex:'{subsetParams.ResultSetIndex}', RowsStartIndex'{subsetParams.RowsStartIndex}', Requested RowsCount:'{subsetParams.RowsCount}'\r\n\t\t with subset response of:[ RowCount:'{subset.RowCount}', Rows array of length:'{subset.Rows.Length}']");
}
catch (Exception e)
{
@@ -690,7 +689,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
}
catch (Exception ex)
{
- Logger.Write(TraceEventType.Error, "Unknown error " + ex.ToString());
+ Logger.Error("Unknown error " + ex.ToString());
}
await Task.FromResult(true);
}
@@ -765,7 +764,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
throw new InvalidOperationException(SR.QueryServiceQueryInProgress);
}
- Logger.Write(TraceEventType.Information, $"Query object for URI:'{executeParams.OwnerUri}' created");
+ Logger.Information($"Query object for URI:'{executeParams.OwnerUri}' created");
return newQuery;
}
@@ -784,7 +783,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
BatchSummaries = q.BatchSummaries
};
- Logger.Write(TraceEventType.Information, $"Query:'{ownerUri}' completed");
+ Logger.Information($"Query:'{ownerUri}' completed");
await eventSender.SendEvent(QueryCompleteEvent.Type, eventParams);
};
@@ -798,7 +797,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
BatchSummaries = q.BatchSummaries
};
- Logger.Write(TraceEventType.Error, $"Query:'{ownerUri}' failed");
+ Logger.Error($"Query:'{ownerUri}' failed");
await eventSender.SendEvent(QueryCompleteEvent.Type, eventParams);
};
query.QueryCompleted += completeCallback;
@@ -818,7 +817,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Batch:'{b.Summary}' on Query:'{ownerUri}' started");
+ Logger.Information($"Batch:'{b.Summary}' on Query:'{ownerUri}' started");
await eventSender.SendEvent(BatchStartEvent.Type, eventParams);
};
query.BatchStarted += batchStartCallback;
@@ -831,7 +830,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Batch:'{b.Summary}' on Query:'{ownerUri}' completed");
+ Logger.Information($"Batch:'{b.Summary}' on Query:'{ownerUri}' completed");
await eventSender.SendEvent(BatchCompleteEvent.Type, eventParams);
};
query.BatchCompleted += batchCompleteCallback;
@@ -844,7 +843,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Message generated on Query:'{ownerUri}' :'{m}'");
+ Logger.Information($"Message generated on Query:'{ownerUri}' :'{m}'");
await eventSender.SendEvent(MessageEvent.Type, eventParams);
};
query.BatchMessageSent += batchMessageCallback;
@@ -858,7 +857,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Result:'{r.Summary} on Query:'{ownerUri}' is available");
+ Logger.Information($"Result:'{r.Summary} on Query:'{ownerUri}' is available");
await eventSender.SendEvent(ResultSetAvailableEvent.Type, eventParams);
};
query.ResultSetAvailable += resultAvailableCallback;
@@ -872,7 +871,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Result:'{r.Summary} on Query:'{ownerUri}' is updated with additional rows");
+ Logger.Information($"Result:'{r.Summary} on Query:'{ownerUri}' is updated with additional rows");
await eventSender.SendEvent(ResultSetUpdatedEvent.Type, eventParams);
};
query.ResultSetUpdated += resultUpdatedCallback;
@@ -886,7 +885,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
OwnerUri = ownerUri
};
- Logger.Write(TraceEventType.Information, $"Result:'{r.Summary} on Query:'{ownerUri}' is complete");
+ Logger.Information($"Result:'{r.Summary} on Query:'{ownerUri}' is complete");
await eventSender.SendEvent(ResultSetCompleteEvent.Type, eventParams);
};
query.ResultSetCompleted += resultCompleteCallback;
@@ -1045,7 +1044,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
{
// We don't particularly care if we fail to cancel during shutdown
string message = string.Format("Failed to cancel query {0} during query service disposal: {1}", query.Key, e);
- Logger.Write(TraceEventType.Warning, message);
+ Logger.Warning(message);
}
}
query.Value.Dispose();
diff --git a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/ResultSet.cs b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/ResultSet.cs
index e74560de..4acff087 100644
--- a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/ResultSet.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/ResultSet.cs
@@ -629,7 +629,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
if (!currentResultSetSnapshot.hasCompletedRead &&
LastUpdatedSummary.RowCount == currentResultSetSnapshot.RowCount)
{
- Logger.Write(TraceEventType.Warning,
+ Logger.Warning(
$"The result set:{Summary} has not made any progress in last {ResultTimerInterval} milliseconds and the read of this result set is not yet complete!");
ResultsIntervalMultiplier++;
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/SerializationService.cs b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/SerializationService.cs
index ba0943bf..c86ab6da 100644
--- a/src/Microsoft.Kusto.ServiceLayer/QueryExecution/SerializationService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/QueryExecution/SerializationService.cs
@@ -8,7 +8,6 @@
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
-using System.Diagnostics;
using System.Threading.Tasks;
using Microsoft.SqlTools.Extensibility;
using Microsoft.SqlTools.Hosting;
@@ -33,7 +32,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
public override void InitializeService(IProtocolEndpoint serviceHost)
{
- Logger.Write(TraceEventType.Verbose, "SerializationService initialized");
+ Logger.Verbose("SerializationService initialized");
serviceHost.SetRequestHandler(SerializeStartRequest.Type, HandleSerializeStartRequest);
serviceHost.SetRequestHandler(SerializeContinueRequest.Type, HandleSerializeContinueRequest);
}
@@ -73,7 +72,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
inProgressSerializations.AddOrUpdate(serializer.FilePath, serializer, (key, old) => serializer);
}
- Logger.Write(TraceEventType.Verbose, "HandleSerializeStartRequest");
+ Logger.Verbose("HandleSerializeStartRequest");
SerializeDataResult result = serializer.ProcessRequest(serializeParams);
await requestContext.SendResult(result);
}
@@ -134,7 +133,7 @@ namespace Microsoft.Kusto.ServiceLayer.QueryExecution
}
// Write to file and cleanup if needed
- Logger.Write(TraceEventType.Verbose, "HandleSerializeContinueRequest");
+ Logger.Verbose("HandleSerializeContinueRequest");
SerializeDataResult result = serializer.ProcessRequest(serializeParams);
if (serializeParams.IsLastBatch)
{
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptAsScriptingOperation.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptAsScriptingOperation.cs
index e3b099e2..91ed6c08 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptAsScriptingOperation.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptAsScriptingOperation.cs
@@ -14,7 +14,6 @@ using Microsoft.SqlServer.Management.Common;
using Microsoft.SqlServer.Management.Smo;
using Microsoft.SqlServer.Management.SqlScriptPublish;
using Microsoft.SqlServer.Management.Sdk.Sfc;
-using System.Diagnostics;
namespace Microsoft.Kusto.ServiceLayer.Scripting
{
@@ -72,8 +71,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
this.CancellationToken.ThrowIfCancellationRequested();
- Logger.Write(
- TraceEventType.Verbose,
+ Logger.Verbose(
string.Format(
"Sending script complete notification event for operation {0}",
this.OperationId
@@ -96,7 +94,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
{
if (e.IsOperationCanceledException())
{
- Logger.Write(TraceEventType.Information, string.Format("Scripting operation {0} was canceled", this.OperationId));
+ Logger.Information(string.Format("Scripting operation {0} was canceled", this.OperationId));
this.SendCompletionNotificationEvent(new ScriptingCompleteParams
{
Canceled = true,
@@ -104,7 +102,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
}
else
{
- Logger.Write(TraceEventType.Error, string.Format("Scripting operation {0} failed with exception {1}", this.OperationId, e));
+ Logger.Error(string.Format("Scripting operation {0} failed with exception {1}", this.OperationId, e));
this.SendCompletionNotificationEvent(new ScriptingCompleteParams
{
OperationId = OperationId,
@@ -226,7 +224,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
{
//If you are getting this assertion fail it means you are working for higher
//version of SQL Server. You need to update this part of code.
- Logger.Write(TraceEventType.Warning, "This part of the code is not updated corresponding to latest version change");
+ Logger.Warning("This part of the code is not updated corresponding to latest version change");
}
// for cloud scripting to work we also have to have Script Compat set to 105.
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingExtensionMethods.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingExtensionMethods.cs
index 61a405c7..0c2c9b7e 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingExtensionMethods.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingExtensionMethods.cs
@@ -6,7 +6,6 @@
#nullable disable
using System.Collections.Generic;
-using System.Diagnostics;
using System.Linq;
using Microsoft.SqlServer.Management.Sdk.Sfc;
using Microsoft.SqlServer.Management.SqlScriptPublish;
@@ -59,8 +58,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
List databaseObjects = new List();
IEnumerable objectTypes = publishModel.GetDatabaseObjectTypes();
- Logger.Write(
- TraceEventType.Verbose,
+ Logger.Verbose(
string.Format(
"Loaded SMO object type count {0}, types: {1}",
objectTypes.Count(),
@@ -70,8 +68,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
{
IEnumerable> databaseObjectsOfType = publishModel.EnumChildrenForDatabaseObjectType(objectType);
- Logger.Write(
- TraceEventType.Verbose,
+ Logger.Verbose(
string.Format(
"Loaded SMO urn object count {0} for type {1}, urns: {2}",
objectType,
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingListObjectsOperation.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingListObjectsOperation.cs
index 51081968..94afbf64 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingListObjectsOperation.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingListObjectsOperation.cs
@@ -10,7 +10,6 @@ using System.Collections.Generic;
using Microsoft.SqlServer.Management.SqlScriptPublish;
using Microsoft.Kusto.ServiceLayer.Scripting.Contracts;
using Microsoft.SqlTools.Utility;
-using System.Diagnostics;
using Microsoft.Kusto.ServiceLayer.DataSource;
namespace Microsoft.Kusto.ServiceLayer.Scripting
@@ -55,8 +54,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
publishModel = new SqlScriptPublishModel(this.Parameters.ConnectionString);
List databaseObjects = publishModel.GetDatabaseObjects();
- Logger.Write(
- TraceEventType.Verbose,
+ Logger.Verbose(
string.Format(
"Sending list object completion notification count {0}, objects: {1}",
databaseObjects,
@@ -73,7 +71,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
}
catch (Exception e)
{
- Logger.Write(TraceEventType.Information, string.Format("Scripting operation {0} was canceled", this.OperationId));
+ Logger.Information(string.Format("Scripting operation {0} was canceled", this.OperationId));
if (e.IsOperationCanceledException())
{
this.SendCompletionNotificationEvent(new ScriptingListObjectsCompleteParams
@@ -84,7 +82,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
}
else
{
- Logger.Write(TraceEventType.Error, string.Format("Scripting operation {0} failed with exception {1}", this.OperationId, e));
+ Logger.Error(string.Format("Scripting operation {0} failed with exception {1}", this.OperationId, e));
this.SendCompletionNotificationEvent(new ScriptingListObjectsCompleteParams
{
OperationId = this.OperationId,
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingOperation.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingOperation.cs
index e321419c..4a38c506 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingOperation.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingOperation.cs
@@ -4,7 +4,6 @@
//
using System;
-using System.Diagnostics;
using System.Threading;
using Microsoft.SqlTools.Utility;
@@ -43,7 +42,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
{
if (!this.cancellation.IsCancellationRequested)
{
- Logger.Write(TraceEventType.Verbose, string.Format("Cancel invoked for OperationId {0}", this.OperationId));
+ Logger.Verbose(string.Format("Cancel invoked for OperationId {0}", this.OperationId));
this.cancellation.Cancel();
}
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingService.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingService.cs
index c9e23649..2399db79 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingService.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/ScriptingService.cs
@@ -7,7 +7,6 @@
using System;
using System.Collections.Concurrent;
-using System.Diagnostics;
using System.Threading.Tasks;
using Microsoft.SqlTools.Hosting.Protocol;
using Microsoft.SqlTools.Hosting.Protocol.Contracts;
@@ -159,7 +158,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
}
else
{
- Logger.Write(TraceEventType.Information, string.Format("Operation {0} was not found", operation.OperationId));
+ Logger.Information(string.Format("Operation {0} was not found", operation.OperationId));
}
await requestContext.SendResult(new ScriptingCancelResult());
diff --git a/src/Microsoft.Kusto.ServiceLayer/Scripting/SmoScriptingOperation.cs b/src/Microsoft.Kusto.ServiceLayer/Scripting/SmoScriptingOperation.cs
index 116582d2..163f7518 100644
--- a/src/Microsoft.Kusto.ServiceLayer/Scripting/SmoScriptingOperation.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/Scripting/SmoScriptingOperation.cs
@@ -9,7 +9,6 @@ using Microsoft.Kusto.ServiceLayer.Scripting.Contracts;
using Microsoft.Kusto.ServiceLayer.DataSource;
using Microsoft.SqlTools.Utility;
using System;
-using System.Diagnostics;
using System.IO;
using System.Reflection;
using static Microsoft.SqlServer.Management.SqlScriptPublish.SqlScriptOptions;
@@ -75,7 +74,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
protected string GetServerNameFromLiveInstance()
{
- Logger.Write(TraceEventType.Verbose, string.Format("Resolved server name '{0}'", _dataSource.ClusterName));
+ Logger.Verbose(string.Format("Resolved server name '{0}'", _dataSource.ClusterName));
return _dataSource.ClusterName;
}
@@ -102,7 +101,7 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
{
if (scriptOptionsParameters == null)
{
- Logger.Write(TraceEventType.Verbose, "No advanced options set, the ScriptOptions object is null.");
+ Logger.Verbose("No advanced options set, the ScriptOptions object is null.");
return;
}
@@ -111,14 +110,14 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
PropertyInfo advancedOptionPropInfo = advancedOptions.GetType().GetProperty(optionPropInfo.Name);
if (advancedOptionPropInfo == null)
{
- Logger.Write(TraceEventType.Warning, string.Format("Invalid property info name {0} could not be mapped to a property on SqlScriptOptions.", optionPropInfo.Name));
+ Logger.Warning(string.Format("Invalid property info name {0} could not be mapped to a property on SqlScriptOptions.", optionPropInfo.Name));
continue;
}
object optionValue = optionPropInfo.GetValue(scriptOptionsParameters, index: null);
if (optionValue == null)
{
- Logger.Write(TraceEventType.Verbose, string.Format("Skipping ScriptOptions.{0} since value is null", optionPropInfo.Name));
+ Logger.Verbose(string.Format("Skipping ScriptOptions.{0} since value is null", optionPropInfo.Name));
continue;
}
@@ -148,14 +147,12 @@ namespace Microsoft.Kusto.ServiceLayer.Scripting
smoValue = Enum.Parse(advancedOptionPropInfo.PropertyType, (string)optionValue, ignoreCase: true);
}
- Logger.Write(TraceEventType.Verbose, string.Format("Setting ScriptOptions.{0} to value {1}", optionPropInfo.Name, smoValue));
+ Logger.Verbose(string.Format("Setting ScriptOptions.{0} to value {1}", optionPropInfo.Name, smoValue));
advancedOptionPropInfo.SetValue(advancedOptions, smoValue);
}
catch (Exception e)
{
- Logger.Write(
- TraceEventType.Warning,
- string.Format("An exception occurred setting option {0} to value {1}: {2}", optionPropInfo.Name, optionValue, e));
+ Logger.Warning(string.Format("An exception occurred setting option {0} to value {1}: {2}", optionPropInfo.Name, optionValue, e));
}
}
diff --git a/src/Microsoft.Kusto.ServiceLayer/ServiceHost.cs b/src/Microsoft.Kusto.ServiceLayer/ServiceHost.cs
index 8cdf6c56..b9214d5f 100644
--- a/src/Microsoft.Kusto.ServiceLayer/ServiceHost.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/ServiceHost.cs
@@ -5,7 +5,6 @@
using System;
using System.Collections.Generic;
-using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;
@@ -144,7 +143,7 @@ namespace Microsoft.Kusto.ServiceLayer
///
private async Task HandleShutdownRequest(object shutdownParams, RequestContext