Method initialize

crates/core/src/plugins/nemo_guardrails/python.rs:451–470

(&self, config: &NeMoGuardrailsConfig)

    }

    fn initialize(&self, config: &NeMoGuardrailsConfig) -> PluginResult<()> {
        let response = self
            .request_blocking(
                json!({
                    "command": "init",
                    "config": config,
                }),
                WORKER_INIT_TIMEOUT,
            )
            .map_err(|err| PluginError::RegistrationFailed(err.to_string()))?;
        if response.ok {
            Ok(())
        } else {
            Err(PluginError::RegistrationFailed(
                response
                    .error
                    .unwrap_or_else(|| "NeMo Guardrails local Python worker failed".to_string()),
            ))
        }
    }

    async fn request(&self, mut payload: Json) -> FlowResult<Json> {
        let receiver = self.send_request(&mut payload)?;