diff --git a/cmd/recordcollector/main.go b/cmd/recordcollector/main.go
index 44f6014..d168dc8 100644
--- a/cmd/recordcollector/main.go
+++ b/cmd/recordcollector/main.go
@@ -183,29 +183,6 @@ func (h *handler) runRefreshSession(ctx context.Context) {
 }
 
 func (h *handler) addLabel(ctx context.Context, did, label string) error {
-	now := time.Now().UTC()
-
-	_, err := h.db.ExecContext(ctx, "delete from label where exp < ?", now.Unix())
-	if err != nil {
-		h.logger.Error("failed to trim expired labels", "err", err)
-		return fmt.Errorf("failed to trim expired labels: %w", err)
-	}
-
-	var uri string
-	checkQuery := "select uri from label where uri = ? and val = ?"
-	err = h.db.QueryRowContext(ctx, checkQuery, did, label).Scan(&uri)
-	if err == sql.ErrNoRows {
-		h.logger.Info("no existing labels found for did, adding", "did", did, "label", label)
-	} else if err != nil {
-		h.logger.Error("failed query for existing labels", "err", err)
-		return fmt.Errorf("failed query for existing labels: %w", err)
-	}
-
-	if uri != "" {
-		h.logger.Info("did already has label, skipping", "did", did, "label", label)
-		return nil
-	}
-
 	var labelDuration int64 = 24 * 30
 	input := &toolsozone.ModerationEmitEvent_Input{
 		CreatedBy: RecordCollectorDid,
@@ -230,16 +207,6 @@ func (h *handler) addLabel(ctx context.Context, did, label string) error {
 	}
 	h.logger.Info("added label", "view", view)
 
-	addQuery := "insert into label (uri, val, cts, exp) values (?, ?, ?, ?)"
-	// we set this to 28 days so a user can "re-up" a label within 48 hours
-	// of its expiration within the appview
-	exp := now.Add(time.Hour * 24 * 28)
-	_, err = h.db.ExecContext(ctx, addQuery, did, label, now.Unix(), exp.Unix())
-	if err != nil {
-		h.logger.Error("failed adding label to table", "err", err)
-		return fmt.Errorf("failed adding label to table: %w", err)
-	}
-
 	return nil
 }