Skip to content

Commit

Permalink
feat: DTOSS-6682-sonarqube-fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Swapnil261188 committed Jan 15, 2025
1 parent 60c2737 commit 8a44252
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ public ProcessRecordsManager(
/// Thrown if the maximum number of retry attempts is reached and the file cannot be processed successfully.
/// </exception>
public async Task ProcessRecordsWithRetry(
List<ParticipantsParquetMap> value,
List<ParticipantsParquetMap> values,
ParallelOptions options,
ScreeningService screeningService,
string name)
Expand All @@ -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)
{
Expand All @@ -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)
Expand Down

0 comments on commit 8a44252

Please sign in to comment.