We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 78ceed6 commit dd5c44fCopy full SHA for dd5c44f
src/core/pipeline_runner.rs
@@ -832,7 +832,6 @@ impl<T: Operator + Send + Sync + 'static> OperatorProcessor<T> {
832
}
833
834
835
-#[expect(clippy::excessive_nesting, reason = "Nesting is manageable here")]
836
#[async_trait]
837
impl<T: Operator + Send + Sync + 'static> NodeProcessor for OperatorProcessor<T> {
838
async fn process_incoming_packet(
0 commit comments