Update to newest package and use parallel (#15)

Energinet-DataHub · Sep 10, 2024 · e3fd72f · e3fd72f
1 parent 774745b
commit e3fd72f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/source/settlement-report/Common.Infrastructure/Common.Infrastructure.csproj b/source/settlement-report/Common.Infrastructure/Common.Infrastructure.csproj
@@ -22,7 +22,7 @@ limitations under the License.
     <PackageReference Include="AspNetCore.HealthChecks.AzureServiceBus" Version="8.0.1" />
     <PackageReference Include="Azure.Identity" Version="1.11.4" />
     <PackageReference Include="Azure.Storage.Files.DataLake" Version="12.17.1" />
-    <PackageReference Include="Energinet.DataHub.Core.Databricks.SqlStatementExecution" Version="11.0.0" />
+    <PackageReference Include="Energinet.DataHub.Core.Databricks.SqlStatementExecution" Version="11.2.0" />
     <PackageReference Include="Energinet.DataHub.Core.Databricks.Jobs" Version="11.0.0" />
     <PackageReference Include="Energinet.DataHub.Core.App.Common.Abstractions" Version="12.2.1" />
     <PackageReference Include="Microsoft.ApplicationInsights" Version="2.22.0" />

diff --git a/...lement-report/SettlementReports.Infrastructure/Experimental/DatabricksSqlQueryExecutor.cs b/...lement-report/SettlementReports.Infrastructure/Experimental/DatabricksSqlQueryExecutor.cs
@@ -61,7 +61,7 @@ internal string BuildDebugString(DatabricksSqlQueryable query)
 
     private IAsyncEnumerable<TElement> ExecuteCoreAsync<TElement>(DatabricksStatement databricksStatement, CancellationToken cancellationToken = default)
     {
-        var rows = _databricksSqlWarehouseQueryExecutor.ExecuteStatementAsync(databricksStatement, Format.JsonArray, cancellationToken);
+        var rows = _databricksSqlWarehouseQueryExecutor.ExecuteStatementAsync(databricksStatement, QueryOptions.WithFormat(Format.JsonArray).WithParallelDownload(), cancellationToken);
         return _sqlRowHydrator.HydrateAsync<TElement>(rows, cancellationToken);
     }