@@ -1896,7 +1896,7 @@ impl EnvelopeProcessorService {
1896
1896
}
1897
1897
1898
1898
macro_rules! run {
1899
- ( $fn_name: ident ( $( $args: expr) ,* ) ) => { {
1899
+ ( $fn_name: ident , $( $args: expr) ,* ) => { {
1900
1900
let managed_envelope = managed_envelope. try_into( ) ?;
1901
1901
let mut state = self . prepare_state(
1902
1902
self . inner. config. clone( ) ,
@@ -1926,15 +1926,15 @@ impl EnvelopeProcessorService {
1926
1926
relay_log:: trace!( "Processing {group} group" , group = group. variant( ) ) ;
1927
1927
1928
1928
match group {
1929
- ProcessingGroup :: Error => run ! ( process_errors( ) ) ,
1930
- ProcessingGroup :: Transaction => run ! ( process_transactions( reservoir_counters) ) ,
1931
- ProcessingGroup :: Session => run ! ( process_sessions( ) ) ,
1932
- ProcessingGroup :: Standalone => run ! ( process_standalone( ) ) ,
1933
- ProcessingGroup :: ClientReport => run ! ( process_client_reports( ) ) ,
1934
- ProcessingGroup :: Replay => run ! ( process_replays( ) ) ,
1935
- ProcessingGroup :: CheckIn => run ! ( process_checkins( ) ) ,
1936
- ProcessingGroup :: Span => run ! ( process_standalone_spans( reservoir_counters) ) ,
1937
- ProcessingGroup :: ProfileChunk => run ! ( process_profile_chunks( ) ) ,
1929
+ ProcessingGroup :: Error => run ! ( process_errors, ) ,
1930
+ ProcessingGroup :: Transaction => run ! ( process_transactions, reservoir_counters) ,
1931
+ ProcessingGroup :: Session => run ! ( process_sessions, ) ,
1932
+ ProcessingGroup :: Standalone => run ! ( process_standalone, ) ,
1933
+ ProcessingGroup :: ClientReport => run ! ( process_client_reports, ) ,
1934
+ ProcessingGroup :: Replay => run ! ( process_replays, ) ,
1935
+ ProcessingGroup :: CheckIn => run ! ( process_checkins, ) ,
1936
+ ProcessingGroup :: Span => run ! ( process_standalone_spans, reservoir_counters) ,
1937
+ ProcessingGroup :: ProfileChunk => run ! ( process_profile_chunks, ) ,
1938
1938
// Currently is not used.
1939
1939
ProcessingGroup :: Metrics => {
1940
1940
// In proxy mode we simply forward the metrics.
0 commit comments