Method request

crates/core/src/plugins/nemo_guardrails/python.rs:472–490

(&self, mut payload: Json)

    }

    async fn request(&self, mut payload: Json) -> FlowResult<Json> {
        let receiver = self.send_request(&mut payload)?;
        let response_task = tokio::task::spawn_blocking(move || receiver.recv());
        let envelope = match tokio::time::timeout(WORKER_RPC_TIMEOUT, response_task).await {
            Ok(result) => result
                .map_err(|err| FlowError::Internal(format!("worker response task failed: {err}")))?
                .map_err(|err| {
                    FlowError::Internal(format!("worker response channel closed: {err}"))
                })?,
            Err(_) => {
                self.shutdown();
                return Err(FlowError::Internal(format!(
                    "worker request timed out after {} seconds",
                    WORKER_RPC_TIMEOUT.as_secs()
                )));
            }
        };
        worker_result(envelope)
    }

    fn request_blocking(&self, mut payload: Json, timeout: Duration) -> FlowResult<WorkerEnvelope> {
        let receiver = self.send_request(&mut payload)?;