From 4fd0bdcf2f180d66f03107e26fb270c1c7ec4d42 Mon Sep 17 00:00:00 2001 From: tobi Date: Mon, 29 Sep 2025 12:11:37 +0200 Subject: [PATCH] should be done poking now --- .../bundb/migrations/20250415111056_thread_all_statuses.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/internal/db/bundb/migrations/20250415111056_thread_all_statuses.go b/internal/db/bundb/migrations/20250415111056_thread_all_statuses.go index 7b864a445..0e67d1d7d 100644 --- a/internal/db/bundb/migrations/20250415111056_thread_all_statuses.go +++ b/internal/db/bundb/migrations/20250415111056_thread_all_statuses.go @@ -92,7 +92,7 @@ func init() { Column("id"). Where("? < ?", bun.Ident("id"), maxID). OrderExpr("? DESC", bun.Ident("id")). - Limit(1000). + Limit(200). Scan(ctx); err != nil && !errors.Is(err, sql.ErrNoRows) { return gtserror.Newf("error selecting unthreaded statuses: %w", err) } @@ -265,9 +265,6 @@ func (sr *statusRethreader) rethreadStatus(ctx context.Context, tx bun.Tx, statu // Ensure the passed status // has up-to-date information. - // This may have changed from - // the initial batch selection - // to the rethreadStatus() call. upToDateValues := make(map[string]any, 3) if err := tx.NewSelect(). TableExpr("? AS ?", bun.Ident("statuses"), bun.Ident("status")).