Avoid making error on every actuator output (#1114)

restatedev · Jan 25, 2024 · d094da3 · d094da3
1 parent 1b7f355
commit d094da3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/worker/src/partition/mod.rs b/crates/worker/src/partition/mod.rs
@@ -221,7 +221,7 @@ where
                 },
                 actuator_output = actuator_stream.next() => {
                     counter!(PARTITION_ACTUATOR_HANDLED).increment(1);
-                    let actuator_output = actuator_output.ok_or(anyhow::anyhow!("actuator stream is closed"))?;
+                    let actuator_output = actuator_output.ok_or_else(|| anyhow::anyhow!("actuator stream is closed"))?;
                     actuator_output_handler.handle(actuator_output).await;
                 },
                 task_result = leadership_state.run_tasks() => {