fix: do not decode twice on lookback

infinyon · Jul 25, 2023 · 1990028 · 1990028
1 parent 07f3450
commit 1990028
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/crates/fluvio-smartmodule-derive/src/generator/look_back.rs b/crates/fluvio-smartmodule-derive/src/generator/look_back.rs
@@ -36,10 +36,6 @@ pub fn generate_look_back_smartmodule(sm_func: &SmartModuleFn) -> TokenStream {
                 let base_offset = smartmodule_input.base_offset();
                 let records_input = smartmodule_input.into_raw_bytes();
 
-                if let Err(_err) = Decoder::decode(&mut records, &mut std::io::Cursor::new(records_input), version) {
-                    return SmartModuleLookbackErrorStatus::DecodingRecords as i32;
-                };
-
                 // PROCESSING
                 for record in records.into_iter() {
                     let result = super:: #user_fn(&record);