diff --git a/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts b/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
index a078b578e4..9ec5d13591 100644
--- a/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
+++ b/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
@@ -165,9 +165,14 @@ export class DefaultProviderDatabase implements ProviderDatabase {
 
           await tx<DbRefreshStateReferencesRow>('refresh_state_references')
             .where('target_entity_ref', entityRef)
+            .andWhere({ source_key: options.sourceKey })
             .delete();
 
           if (ok) {
+            await tx<DbRefreshStateReferencesRow>('refresh_state_references')
+              .where('target_entity_ref', entityRef)
+              .delete();
+
             await tx<DbRefreshStateReferencesRow>(
               'refresh_state_references',
             ).insert({