From c204cd7848f8560d694d7a50764046e290e3b2af Mon Sep 17 00:00:00 2001
From: Justin M <63619224+JustinMDotNet@users.noreply.github.com>
Date: Thu, 4 Mar 2021 11:12:21 -0800
Subject: [PATCH] Removed catch block around ExecuteQueryAsync to allow
 exception to bubble up and be returned to ADS. (#1169)

---
 .../DataSource/KustoClient.cs                 | 20 ++++++++-----------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/src/Microsoft.Kusto.ServiceLayer/DataSource/KustoClient.cs b/src/Microsoft.Kusto.ServiceLayer/DataSource/KustoClient.cs
index c766a298..931edf77 100644
--- a/src/Microsoft.Kusto.ServiceLayer/DataSource/KustoClient.cs
+++ b/src/Microsoft.Kusto.ServiceLayer/DataSource/KustoClient.cs
@@ -198,20 +198,16 @@ namespace Microsoft.Kusto.ServiceLayer.DataSource
         /// Executes a query.
         /// </summary>
         /// <param name="query">The query.</param>
+        /// <param name="cancellationToken"></param>
+        /// <param name="databaseName"></param>
         /// <returns>The results.</returns>
-        public async Task<IEnumerable<T>> ExecuteQueryAsync<T>(string query, CancellationToken cancellationToken, string databaseName = null)
+        public async Task<IEnumerable<T>> ExecuteQueryAsync<T>(string query, CancellationToken cancellationToken,
+            string databaseName = null)
         {
-            try
-            {
-                var resultReader = ExecuteQuery(query, cancellationToken, databaseName);
-                var results = KustoDataReaderParser.ParseV1(resultReader, null);
-                var tableReader = results[WellKnownDataSet.PrimaryResult].Single().TableData.CreateDataReader();
-                return await Task.FromResult(new ObjectReader<T>(tableReader));
-            }
-            catch (Exception)
-            {
-                return null;
-            }
+            var resultReader = ExecuteQuery(query, cancellationToken, databaseName);
+            var results = KustoDataReaderParser.ParseV1(resultReader, null);
+            var tableReader = results[WellKnownDataSet.PrimaryResult].Single().TableData.CreateDataReader();
+            return await Task.FromResult(new ObjectReader<T>(tableReader));
         }
 
         private void CancelQuery(string clientRequestId)