Skip to content

Commit

Permalink
Allow pushing to statistics processor and indexer at the same time
Browse files Browse the repository at this point in the history
Required for deletions.
  • Loading branch information
peppy committed Mar 19, 2024
1 parent aa105a1 commit fb2c91d
Showing 1 changed file with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -218,8 +218,6 @@ private void pushCompletedScoreToQueue(BatchInserter inserter)
{
if (scoreStatisticsQueueProcessor != null)
{
Debug.Assert(inserter.ElasticScoreItems.Any());

var scoreStatisticsItems = inserter.ScoreStatisticsItems.ToList();

if (scoreStatisticsItems.Any())
Expand All @@ -229,10 +227,9 @@ private void pushCompletedScoreToQueue(BatchInserter inserter)
Console.WriteLine($"Queued {scoreStatisticsItems.Count} item(s) for statistics processing");
}
}
else if (elasticQueueProcessor != null)
{
Debug.Assert(!inserter.ScoreStatisticsItems.Any());

if (elasticQueueProcessor != null)
{
var elasticItems = inserter.ElasticScoreItems.ToList();

if (elasticItems.Any())
Expand Down

0 comments on commit fb2c91d

Please sign in to comment.