diff --git a/bgs/bgs.go b/bgs/bgs.go
index be7396932..f388e791d 100644
--- a/bgs/bgs.go
+++ b/bgs/bgs.go
@@ -811,7 +811,7 @@ func (bgs *BGS) handleFedEvent(ctx context.Context, host *models.PDS, env *event
 		if host.ID != u.PDS && u.PDS != 0 {
 			log.Warnw("received event for repo from different pds than expected", "repo", evt.Repo, "expPds", u.PDS, "gotPds", host.Host)
 			// Flush any cached DID documents for this user
-			bgs.didr.FlushCacheFor(env.RepoHandle.Did)
+			bgs.didr.FlushCacheFor(env.RepoCommit.Repo)
 
 			subj, err := bgs.createExternalUser(ctx, evt.Repo)
 			if err != nil {