-
-
Notifications
You must be signed in to change notification settings - Fork 4.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
ref(replays): remove unused chunking code #47877
Conversation
Codecov Report
Additional details and impacted files@@ Coverage Diff @@
## master #47877 +/- ##
==========================================
+ Coverage 78.29% 80.81% +2.52%
==========================================
Files 4762 4762
Lines 201354 201285 -69
Branches 11594 11594
==========================================
+ Hits 157644 162667 +5023
+ Misses 43454 38362 -5092
Partials 256 256
|
with metrics.timer("replays.process_recording.store_recording.drop_segments"): | ||
parts.drop() | ||
|
||
|
||
@metrics.wraps("replays.usecases.ingest.ingest_recording_not_chunked") | ||
def ingest_recording_not_chunked( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This should be renamed to ingest_recording
. The other ingest_recording
function can be renamed to _ingest_recording
or merged into the body of this function.
def move_chunks_to_cache_or_skip(message: Message[KafkaPayload]) -> MessageContext: | ||
"""Move chunk messages to cache or skip.""" | ||
def initialize_message_context(message: Message[KafkaPayload]) -> MessageContext: | ||
"""initialize a Sentry transaction and unpack the message.""" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Nit: capitalization.
After merging getsentry/relay#2032, we've observed that we are no longer processing chunked messages (as intended). We can remove the logic for this as it is no longer used.