diff --git a/federation/service/processer_data.go b/federation/service/processer_data.go index 7e0245580..ef4eb7c6e 100644 --- a/federation/service/processer_data.go +++ b/federation/service/processer_data.go @@ -64,7 +64,10 @@ func (dp *dataProcesser) Process(ctx context.Context, payload []byte) (Processer continue } - dp.SyncService.DeleteRecord(ctx, rec) + // Handle edge cases where the data doesn't exist anymore + if rec != nil { + dp.SyncService.DeleteRecord(ctx, rec) + } processed++ continue