diff --git a/pyproject.toml b/pyproject.toml index 01409549597071..9ef18b78e283e3 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -644,3 +644,16 @@ module = [ disallow_any_generics = true disallow_untyped_defs = true # end: stronger typing + +# begin: possibly-undefined checks for issue team critical code +[[tool.mypy.overrides]] +module = [ + "sentry.issues.*", + "sentry.tasks.post_process", + "sentry.event_manager", + "sentry.grouping.*", + "sentry.tasks.store", + "sentry.ingest.consumer.processors" +] +enable_error_code = ["possibly-undefined"] +# end: possibly-undefined diff --git a/src/sentry/tasks/post_process.py b/src/sentry/tasks/post_process.py index 8812eab86375c7..f74f0ffc1e000e 100644 --- a/src/sentry/tasks/post_process.py +++ b/src/sentry/tasks/post_process.py @@ -1068,6 +1068,7 @@ def _get_replay_id(event): kafka_payload = transform_event_for_linking_payload(replay_id, group_event) except ValueError: metrics.incr("post_process.process_replay_link.id_invalid") + return publisher.publish( "ingest-replay-events",