Skip to content

Commit

Permalink
Use bigger pages instead of forcing parallelism (#1216)
Browse files Browse the repository at this point in the history
  • Loading branch information
karashiiro committed Mar 4, 2024
1 parent 576c402 commit 899b9e5
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
2 changes: 1 addition & 1 deletion src/Universalis.DbAccess/DbAccessExtensions.cs
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ public static void AddDbAccessServices(this IServiceCollection sc, IConfiguratio
.WithSpeculativeExecutionPolicy(new ConstantSpeculativeExecutionPolicy(200, 3))
.WithQueryOptions(new QueryOptions()
.SetDefaultIdempotence(true)
.SetPageSize(1000))
.SetPageSize(10000))
.WithMetrics(new PrometheusDataStaxMetricsProvider(), new DriverMetricsOptions()
.SetEnabledNodeMetrics(NodeMetric.AllNodeMetrics)
.SetEnabledSessionMetrics(SessionMetric.AllSessionMetrics))
Expand Down
1 change: 0 additions & 1 deletion src/Universalis.DbAccess/MarketBoard/HistoryDbAccess.cs
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,6 @@ public async Task<History> Retrieve(HistoryQuery query, CancellationToken cancel
LastUploadTimeUnixMilliseconds = new DateTimeOffset(mi.LastUploadTime).ToUnixTimeMilliseconds(),
Sales = marketSales
.AsParallel() // Iterating over the sales retrieved by the DataStax driver is synchronous, so we parallelize it
.WithExecutionMode(ParallelExecutionMode.ForceParallelism)
.ToList(),
};
});
Expand Down

0 comments on commit 899b9e5

Please sign in to comment.