fix condition

Signed-off-by: Kartikay <[email protected]>
authzed · Jan 31, 2025 · 2d48920 · 2d48920
1 parent f95e9b0
commit 2d48920
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/internal/.DS_Store b/internal/.DS_Store
diff --git a/internal/datastore/mysql/watch.go b/internal/datastore/mysql/watch.go
@@ -335,7 +335,7 @@ func (mds *Datastore) loadNamespaceChanges(ctx context.Context, afterRevision ui
 				return
 			}
 		}
-		if createdTxn > afterRevision && createdTxn <= newRevision {
+		if deletedTxn > afterRevision && deletedTxn <= newRevision {
 			if err = stagedChanges.AddDeletedNamespace(ctx, revisions.NewForTransactionID(deletedTxn), loaded.Name); err != nil {
 				return
 			}
@@ -400,7 +400,7 @@ func (mds *Datastore) loadCaveatChanges(ctx context.Context, afterRevision uint6
 				return
 			}
 		}
-		if createdTxn > afterRevision && createdTxn <= newRevision {
+		if deletedTxn > afterRevision && deletedTxn <= newRevision {
 			if err = stagedChanges.AddDeletedCaveat(ctx, revisions.NewForTransactionID(deletedTxn), loaded.Name); err != nil {
 				return
 			}