mirrors/btcpayserver
1
0
Fork 0
mirror of https://github.com/btcpayserver/btcpayserver.git synced 2025-03-10 09:19:24 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fix timeout issues during migration (#6208)

Browse source
This commit is contained in:
Nicolas Dorier 2024-09-10 20:11:07 +09:00 • committed by GitHub
parent 7c92ce771f
commit d4c30866b7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
BTCPayServer/HostedServices/InvoiceBlobMigratorHostedService.cs
View file

@ -23,7 +23,7 @@ namespace BTCPayServer.HostedServices;
public class InvoiceBlobMigratorHostedService : BlobMigratorHostedService<InvoiceData>
{
private readonly PaymentMethodHandlerDictionary _handlers;
public InvoiceBlobMigratorHostedService(
@ -45,7 +45,7 @@ public class InvoiceBlobMigratorHostedService : BlobMigratorHostedService<Invoic
}
protected override Task Reindex(ApplicationDbContext ctx, CancellationToken cancellationToken)
{
return ctx.Database.GetDbConnection().ExecuteAsync(new("REINDEX INDEX \"IX_Invoices_Created\";REINDEX INDEX \"PK_Invoices\";", cancellationToken: cancellationToken));
return ctx.Database.ExecuteSqlRawAsync("REINDEX INDEX \"IX_Invoices_Created\";REINDEX INDEX \"PK_Invoices\";", cancellationToken);
}
protected override DateTimeOffset ProcessEntities(ApplicationDbContext ctx, List<InvoiceData> invoices)
{
@ -78,8 +78,8 @@ public class InvoiceBlobMigratorHostedService : BlobMigratorHostedService<Invoic
protected override async Task PostMigrationCleanup(ApplicationDbContext ctx, CancellationToken cancellationToken)
{
// If this one never run it's not big deal...
await ctx.Database.GetDbConnection().ExecuteAsync(new("VACUUM (ANALYZE) \"Invoices\"", cancellationToken: cancellationToken));
Logs.LogInformation("Post migration VACUUM successfull");
}
Logs.LogInformation("Post-migration VACUUM (ANALYZE)");
await ctx.Database.ExecuteSqlRawAsync("VACUUM (ANALYZE) \"Invoices\"", cancellationToken);
Logs.LogInformation("Post-migration VACUUM (ANALYZE) finished");
}
}