fix condition

Signed-off-by: Kartikay <[email protected]>
authzed · Jan 31, 2025 · d7f80a8 · d7f80a8
1 parent f95e9b0
commit d7f80a8
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/internal/datastore/mysql/watch.go b/internal/datastore/mysql/watch.go
@@ -280,7 +280,6 @@ func (mds *Datastore) loadRelationshipChanges(ctx context.Context, afterRevision
 				return
 			}
 		}
-
 	}
 	if err = rows.Err(); err != nil {
 		return
@@ -335,12 +334,11 @@ 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
 			}
 		}
-
 	}
 
 	if err = rows.Err(); err != nil {
@@ -400,7 +398,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
 			}