Method request_blocking

crates/core/src/plugins/nemo_guardrails/python.rs:492–497

(&self, mut payload: Json, timeout: Duration)

    }

    fn request_blocking(&self, mut payload: Json, timeout: Duration) -> FlowResult<WorkerEnvelope> {
        let receiver = self.send_request(&mut payload)?;
        receiver
            .recv_timeout(timeout)
            .map_err(|err| FlowError::Internal(format!("worker did not initialize: {err}")))
    }

    fn send_request(&self, payload: &mut Json) -> FlowResult<std_mpsc::Receiver<WorkerEnvelope>> {
        let id = self.next_request_id();