Monorepo for Tangled
appview/state: queue entity-state backfill
Lewis: May this revision serve well! <lewis@tangled.org>
+7
+7
appview/state/router.go
+7
appview/state/router.go
···
51
51
if err := db.ReapStaleRunningMigrations(context.Background(), s.db); err != nil {
52
52
s.logger.Warn("failed to reap stale running migrations", "err", err)
53
53
}
54
+
go func() {
55
+
if n, err := db.EnqueueEntityStateBackfill(context.Background(), s.db); err != nil {
56
+
s.logger.Warn("failed to enqueue entity state backfill", "err", err)
57
+
} else if n > 0 {
58
+
s.logger.Info("enqueued entity state backfill", "owners", n)
59
+
}
60
+
}()
54
61
m := migration.NewMigration(s.db, s.oauth, s.idResolver.Directory(), s.logger)
55
62
router.Use(m.BackgroundMigrationMiddleware)
56
63