diff --git a/src/server/worker_task.rs b/src/server/worker_task.rs
index 24b4e3d6..b89f5ba7 100644
--- a/src/server/worker_task.rs
+++ b/src/server/worker_task.rs
@@ -55,7 +55,9 @@ pub async fn worker_is_active(upid: &UPID) -> Result<bool, Error> {
     let sock = server::ctrl_sock_from_pid(upid.pid);
     let cmd = json!({
         "command": "worker-task-status",
-        "upid": upid.to_string(),
+        "args": {
+            "upid": upid.to_string(),
+        },
     });
     let status = super::send_command(sock, cmd).await?;
 
@@ -127,7 +129,9 @@ pub async fn abort_worker(upid: UPID) -> Result<(), Error> {
     let sock = server::ctrl_sock_from_pid(upid.pid);
     let cmd = json!({
         "command": "worker-task-abort",
-        "upid": upid.to_string(),
+        "args": {
+            "upid": upid.to_string(),
+        },
     });
     super::send_command(sock, cmd).map_ok(|_| ()).await
 }