diff --git a/src/sentry/tasks/unmerge.py b/src/sentry/tasks/unmerge.py index b1d75899bb18f6..de172eb90e07da 100644 --- a/src/sentry/tasks/unmerge.py +++ b/src/sentry/tasks/unmerge.py @@ -500,6 +500,14 @@ def unmerge(*posargs, **kwargs): referrer="unmerge", tenant_ids={"organization_id": source.project.organization_id}, ) + # Log info related to this unmerge + logger.info( + "unmerge.check", + extra={ + "source_id": source.id, + "num_events": len(events), + }, + ) # If there are no more events to process, we're done with the migration. if not events: @@ -530,6 +538,15 @@ def unmerge(*posargs, **kwargs): source.update(**get_group_backfill_attributes(caches, source, source_events)) destinations = dict(args.destinations) + # Log info related to this unmerge + logger.info( + "unmerge.destinations", + extra={ + "source_id": source.id, + "source_events": len(source_events), + "destination_events": len(destination_events), + }, + ) # XXX: This is only actually able to create a destination group and migrate # the group hashes if there are events that can be migrated. How do we