Only get status for running reports (#45)

* Only get status for running reports also remove parallel download. * Update SettlementReportListHttpTrigger.cs
Energinet-DataHub · Oct 4, 2024 · c3f4b4e · c3f4b4e
1 parent 4edb5fa
commit c3f4b4e
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 14 deletions.
diff --git a/...stration.SettlementReports/Functions/SettlementReports/SettlementReportListHttpTrigger.cs b/...stration.SettlementReports/Functions/SettlementReports/SettlementReportListHttpTrigger.cs
@@ -99,19 +99,19 @@ private async Task<IEnumerable<RequestedSettlementReportDto>> CheckStatusOfSettl
         {
             var updatedReport = settlementReport;
 
-            var instanceInfo = await durableTaskClient
-                .GetInstanceAsync(settlementReport.RequestId.Id, getInputsAndOutputs: true)
-                .ConfigureAwait(false);
-
-            if (instanceInfo == null)
+            if (settlementReport.Status == SettlementReportStatus.InProgress && settlementReport.JobId == null)
             {
-                // If the orchestration instance is not found, we assume it is running on the other orchestration,
-                // either the heavy or the light one
-                continue;
-            }
+                var instanceInfo = await durableTaskClient
+                    .GetInstanceAsync(settlementReport.RequestId.Id, getInputsAndOutputs: true)
+                    .ConfigureAwait(false);
+
+                if (instanceInfo == null)
+                {
+                    // If the orchestration instance is not found, we assume it is running on the other orchestration,
+                    // either the heavy or the light one
+                    continue;
+                }
 
-            if (settlementReport.Status == SettlementReportStatus.InProgress)
-            {
                 if (instanceInfo.RuntimeStatus
                     is OrchestrationRuntimeStatus.Terminated
                     or OrchestrationRuntimeStatus.Failed)
@@ -130,9 +130,9 @@ await _updateFailedSettlementReportsHandler
                         updatedReport = updatedReport with { Progress = customStatus.OrchestrationProgress };
                     }
                 }
-            }
 
-            finalSettlementReports.Add(updatedReport);
+                finalSettlementReports.Add(updatedReport);
+            }
         }
 
         return finalSettlementReports;

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