diff --git a/src/cli/run/events.test.ts b/src/cli/run/events.test.ts
index f84d032..84b025c 100644
--- a/src/cli/run/events.test.ts
+++ b/src/cli/run/events.test.ts
@@ -39,7 +39,7 @@ describe("event handling", () => {
       properties: { sessionID: "my-session" },
     }
 
-    const events = toAsyncIterable([{ payload }])
+    const events = toAsyncIterable([payload])
     const { processEvents } = await import("./events")
 
     // #when
@@ -59,7 +59,7 @@ describe("event handling", () => {
       properties: { sessionID: "other-session" },
     }
 
-    const events = toAsyncIterable([{ payload }])
+    const events = toAsyncIterable([payload])
     const { processEvents } = await import("./events")
 
     // #when
@@ -84,7 +84,7 @@ describe("event handling", () => {
       properties: { sessionID: "my-session", status: { type: "busy" } },
     }
 
-    const events = toAsyncIterable([{ payload }])
+    const events = toAsyncIterable([payload])
     const { processEvents } = await import("./events")
 
     // #when
diff --git a/src/cli/run/events.ts b/src/cli/run/events.ts
index 9f2ed8f..fe0613d 100644
--- a/src/cli/run/events.ts
+++ b/src/cli/run/events.ts
@@ -35,8 +35,8 @@ export async function processEvents(
     if (ctx.abortController.signal.aborted) break
 
     try {
-      const payload = (event as { payload?: EventPayload }).payload
-      if (!payload) continue
+      const payload = event as EventPayload
+      if (!payload?.type) continue
 
       handleSessionIdle(ctx, payload, state)
       handleSessionStatus(ctx, payload, state)