diff --git a/src/worker.rs b/src/worker.rs index 001d446..0766246 100644 --- a/src/worker.rs +++ b/src/worker.rs @@ -67,7 +67,6 @@ pub enum WorkerToServer { #[serde(rename = "update")] Update { workflow_id: String, - #[serde(flatten)] update: crate::sink::AgentUpdate, }, } diff --git a/src/ws_worker.rs b/src/ws_worker.rs index 1156040..0901fb8 100644 --- a/src/ws_worker.rs +++ b/src/ws_worker.rs @@ -95,7 +95,8 @@ async fn handle_worker_socket(socket: WebSocket, state: Arc) { handle_worker_message(&state_clone, worker_msg).await; } Err(e) => { - tracing::warn!("Failed to parse worker message: {} — raw: {}", e, &text[..text.len().min(200)]); + let preview: String = text.chars().take(200).collect(); + tracing::warn!("Failed to parse worker message: {} — raw: {}", e, preview); } } }