diff --git a/application/CohortManager/src/Functions/CaasIntegration/receiveCaasFile/ProcessFileClasses/ProcessRecordsManager.cs b/application/CohortManager/src/Functions/CaasIntegration/receiveCaasFile/ProcessFileClasses/ProcessRecordsManager.cs index 377a8c15f..b44792a09 100644 --- a/application/CohortManager/src/Functions/CaasIntegration/receiveCaasFile/ProcessFileClasses/ProcessRecordsManager.cs +++ b/application/CohortManager/src/Functions/CaasIntegration/receiveCaasFile/ProcessFileClasses/ProcessRecordsManager.cs @@ -53,7 +53,7 @@ public ProcessRecordsManager( /// Thrown if the maximum number of retry attempts is reached and the file cannot be processed successfully. /// public async Task ProcessRecordsWithRetry( - List value, + List values, ParallelOptions options, ScreeningService screeningService, string name) @@ -70,7 +70,7 @@ public async Task ProcessRecordsWithRetry( "Starting processing with retry attempt {RetryAttempt}, resuming from index {LastProcessedIndex}.", retryCount + 1, lastProcessedIndex); - var remainingRecords = value.Skip(lastProcessedIndex).ToList(); + var remainingRecords = values.Skip(lastProcessedIndex).ToList(); foreach (var record in remainingRecords) { @@ -85,7 +85,7 @@ public async Task ProcessRecordsWithRetry( } _logger.LogInformation("Processed participant {ParticipantId}.", participant.ParticipantId); - int currentIndex = value.IndexOf(record) + 1; + int currentIndex = values.IndexOf(record) + 1; await _stateStore.UpdateLastProcessedRecordIndex(name, currentIndex); } catch (Exception recordEx)