diff --git a/src/worker_runner.rs b/src/worker_runner.rs
index 2213e16..2e7d112 100644
--- a/src/worker_runner.rs
+++ b/src/worker_runner.rs
@@ -135,7 +135,7 @@ async fn connect_and_run(server_url: &str, worker_name: &str, llm_config: &crate
 
                 let llm = LlmClient::new(llm_config);
                 let exec = LocalExecutor::new(None);
-                let workdir = format!("/app/data/workspaces/{}", project_id);
+                let workdir = format!("workspaces/{}", project_id);
                 let instructions = String::new(); // TODO: load from template
 
                 // update channel → serialize → WebSocket
diff --git a/src/ws_worker.rs b/src/ws_worker.rs
index 2a20ff3..1156040 100644
--- a/src/ws_worker.rs
+++ b/src/ws_worker.rs
@@ -90,8 +90,13 @@ async fn handle_worker_socket(socket: WebSocket, state: Arc<WsWorkerState>) {
         while let Some(Ok(msg)) = receiver.next().await {
             match msg {
                 Message::Text(text) => {
-                    if let Ok(worker_msg) = serde_json::from_str::<WorkerToServer>(&text) {
-                        handle_worker_message(&state_clone, worker_msg).await;
+                    match serde_json::from_str::<WorkerToServer>(&text) {
+                        Ok(worker_msg) => {
+                            handle_worker_message(&state_clone, worker_msg).await;
+                        }
+                        Err(e) => {
+                            tracing::warn!("Failed to parse worker message: {} — raw: {}", e, &text[..text.len().min(200)]);
+                        }
                     }
                 }
                 Message::Close(_) => break,