diff --git a/internal/cmd/scheduler.go b/internal/cmd/scheduler.go
index e7e8009..ed17ebc 100644
--- a/internal/cmd/scheduler.go
+++ b/internal/cmd/scheduler.go
@@ -456,7 +456,13 @@ func enqueueAccounts(ctx context.Context, logger *zap.Logger, statsd *statsd.Cli
 
 	now := time.Now()
 
-	query := `SELECT reddit_account_id FROM accounts`
+	query := `
+		SET work_mem TO '16MB';
+		SELECT DISTINCT reddit_account_id FROM accounts
+		INNER JOIN devices_accounts ON devices_accounts.account_id = accounts.id
+		INNER JOIN devices ON devices.id = devices_accounts.device_id
+		WHERE grace_period_expires_at >= NOW();
+	`
 	rows, err := pool.Query(ctx, query)
 	if err != nil {
 		logger.Error("failed to fetch accounts", zap.Error(err))