diff --git a/src/runtime2/component/component_pdl.rs b/src/runtime2/component/component_pdl.rs index c48b57a00d32408e51cf6dabd5eff7600a550d0c..fcd9a8fe33a342cbaed4babdfef2d85ad7512f25 100644 --- a/src/runtime2/component/component_pdl.rs +++ b/src/runtime2/component/component_pdl.rs @@ -235,7 +235,7 @@ impl Component for CompPDL { fn handle_message(&mut self, sched_ctx: &mut SchedulerCtx, comp_ctx: &mut CompCtx, mut message: Message) { sched_ctx.log(&format!("handling message: {:#?}", message)); if let Some(new_target) = self.control.should_reroute(&mut message) { - let mut target = sched_ctx.runtime.get_component_public(new_target); + let mut target = sched_ctx.runtime.get_component_public(new_target); // TODO: @NoDirectHandle target.send_message(&sched_ctx.runtime, message, false); // not waking up: we schedule once we've received all PortPeerChanged Acks let _should_remove = target.decrement_users(); debug_assert!(_should_remove.is_none());