diff --git a/runtime/src/main.rs b/runtime/src/main.rs index 3db914bb..6e4d79d1 100644 --- a/runtime/src/main.rs +++ b/runtime/src/main.rs @@ -72,13 +72,6 @@ async fn main() -> eyre::Result<()> { ) })?; - println!( - "Received input {} for operator {}: {}", - input.id, - input.target_operator, - String::from_utf8_lossy(&input.data) - ); - operator .handle_input(input.id.clone(), input.data) .wrap_err_with(|| { diff --git a/runtime/src/operator/shared_lib.rs b/runtime/src/operator/shared_lib.rs index d7c3e713..5d642801 100644 --- a/runtime/src/operator/shared_lib.rs +++ b/runtime/src/operator/shared_lib.rs @@ -60,7 +60,6 @@ impl<'lib> SharedLibraryOperator<'lib> { let data_start = input.value.as_slice().as_ptr(); let data_len = input.value.len(); - println!("Received input {}", input.id); let output = |id: &str, data: &[u8]| -> isize { let result = self.events_tx.blocking_send(OperatorEvent::Output { id: id.to_owned().into(),