diff --git a/binaries/runtime/src/lib.rs b/binaries/runtime/src/lib.rs
index 9b4c1f49..f1336648 100644
--- a/binaries/runtime/src/lib.rs
+++ b/binaries/runtime/src/lib.rs
@@ -199,11 +199,13 @@ async fn run(
                     continue;
                 };
 
-                let _ = operator_channel.send(operator::IncomingEvent::Input {
-                    input_id,
-                    metadata,
-                    data,
-                });
+                operator_channel
+                    .send(operator::IncomingEvent::Input {
+                        input_id,
+                        metadata,
+                        data,
+                    })
+                    .await?;
             }
             Event::InputClosed(_) => {}
             Event::Error(err) => eyre::bail!("received error event: {err}"),