Method send

crates/core/src/plugins/nemo_guardrails/python.rs:623–639

(&self, line: String)

    }

    fn send(&self, line: String) -> FlowResult<()> {
        if let Some(error) = self
            .error
            .lock()
            .map_err(|err| {
                FlowError::Internal(format!("worker writer error lock poisoned: {err}"))
            })?
            .clone()
        {
            return Err(FlowError::Internal(format!(
                "failed to write worker command: {error}"
            )));
        }
        self.sender.send(line).map_err(|err| {
            FlowError::Internal(format!("worker command writer channel closed: {err}"))
        })
    }

    fn join(mut self) {
        drop(self.sender);