Skip to content

Commit

Permalink
fix(rust_snuba): Replacements processors should run healthchecks (#6709)
Browse files Browse the repository at this point in the history
Because of this early-return, additional strategy steps were not being
applied. The branch for make_rust_processor does not use 'return'
  • Loading branch information
untitaker authored Jan 8, 2025
1 parent 886d88d commit b6f1123
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions rust_snuba/src/factory.rs
Original file line number Diff line number Diff line change
Expand Up @@ -170,7 +170,7 @@ impl ProcessingStrategyFactory<KafkaPayload> for ConsumerStrategyFactory {
false,
);

return make_rust_processor_with_replacements(
make_rust_processor_with_replacements(
replacements_step,
func,
&self.logical_topic_name,
Expand All @@ -180,7 +180,7 @@ impl ProcessingStrategyFactory<KafkaPayload> for ConsumerStrategyFactory {
env_config: self.env_config.clone(),
},
self.stop_at_timestamp,
);
)
}
(true, Some(processors::ProcessingFunctionType::ProcessingFunction(func))) => {
make_rust_processor(
Expand Down

0 comments on commit b6f1123

Please sign in to comment.