Method log

core/src/orchestration/workflow.rs:310–316

Emit a best-effort structured log line on the [`WorkflowEvent`] stream. Synchronous and non-failing: a full channel drops the line rather than blocking the workflow.

(&self, level: &str, message: &str, fields: serde_json::Value)

    /// Synchronous and non-failing: a full channel drops the line rather than
    /// blocking the workflow.
    pub fn log(&self, level: &str, message: &str, fields: serde_json::Value) {
        let _ = self.events.send(WorkflowEvent::Log {
            level: level.to_string(),
            message: message.to_string(),
            fields,
        });
    }
}

#[cfg(test)]