diff --git a/src/runtime/connector.rs b/src/runtime/connector.rs index e9bce7685c94520e6df7cf873184512aee407e1f..2aabac130545b88c7fb292d41e42d6a7a12b7493 100644 --- a/src/runtime/connector.rs +++ b/src/runtime/connector.rs @@ -122,6 +122,8 @@ impl<'a> RunContext for ConnectorRunContext<'a>{ taken => unreachable!("prepared statement is '{:?}' during 'performed_fork()'", taken), }; } + + fn performed_select_wait(&mut self) -> Option { unreachable!() } } impl Connector for ConnectorPDL { @@ -463,7 +465,7 @@ impl ConnectorPDL { return ConnectorScheduling::Immediate; }, - EvalContinuation::NewComponent(definition_id, monomorph_idx, arguments) => { + EvalContinuation::NewComponent(definition_id, type_id, arguments) => { // Note: we're relinquishing ownership of ports. But because // we are in non-sync mode the scheduler will handle and check // port ownership transfer. @@ -473,7 +475,7 @@ impl ConnectorPDL { let new_prompt = Prompt::new( &sched_ctx.runtime.protocol_description.types, &sched_ctx.runtime.protocol_description.heap, - definition_id, monomorph_idx, arguments + definition_id, type_id, arguments ); let new_component = ConnectorPDL::new(new_prompt); comp_ctx.push_component(new_component, comp_ctx.workspace_ports.clone());