|
@@ -119,6 +119,11 @@ class SnubaProtocolEventStream(EventStream):
|
|
|
group_states: Optional[GroupStates] = None,
|
|
|
**kwargs: Any,
|
|
|
) -> None:
|
|
|
+ if event.get_tag("sample_event") == "true":
|
|
|
+ logger.info(
|
|
|
+ "insert: attempting to insert event in Snuba",
|
|
|
+ extra={"event.id": event.event_id, "project_id": event.project_id},
|
|
|
+ )
|
|
|
if isinstance(event, GroupEvent) and not event.occurrence:
|
|
|
logger.error(
|
|
|
"`GroupEvent` passed to `EventStream.insert`. `GroupEvent` may only be passed when "
|
|
@@ -175,6 +180,11 @@ class SnubaProtocolEventStream(EventStream):
|
|
|
# transactions processing has a configurable 'skipped contexts' to skip writing specific contexts maps
|
|
|
# to the row. for now, we're ignoring that until we have a need for it
|
|
|
|
|
|
+ if event.get_tag("sample_event") == "true":
|
|
|
+ logger.info(
|
|
|
+ "insert: inserting event in Snuba",
|
|
|
+ extra={"event.id": event.event_id, "project_id": event.project_id},
|
|
|
+ )
|
|
|
self._send(
|
|
|
project.id,
|
|
|
"insert",
|