should be done poking now

This commit is contained in:
tobi 2025-09-29 12:11:37 +02:00 committed by tobi
commit 4fd0bdcf2f

View file

@ -92,7 +92,7 @@ func init() {
Column("id"). Column("id").
Where("? < ?", bun.Ident("id"), maxID). Where("? < ?", bun.Ident("id"), maxID).
OrderExpr("? DESC", bun.Ident("id")). OrderExpr("? DESC", bun.Ident("id")).
Limit(1000). Limit(200).
Scan(ctx); err != nil && !errors.Is(err, sql.ErrNoRows) { Scan(ctx); err != nil && !errors.Is(err, sql.ErrNoRows) {
return gtserror.Newf("error selecting unthreaded statuses: %w", err) 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 // Ensure the passed status
// has up-to-date information. // has up-to-date information.
// This may have changed from
// the initial batch selection
// to the rethreadStatus() call.
upToDateValues := make(map[string]any, 3) upToDateValues := make(map[string]any, 3)
if err := tx.NewSelect(). if err := tx.NewSelect().
TableExpr("? AS ?", bun.Ident("statuses"), bun.Ident("status")). TableExpr("? AS ?", bun.Ident("statuses"), bun.Ident("status")).